# Copyright 2021 VMware, Inc.
# SPDX-License-Identifier: Apache-2.0
from vdk.api.job_input import IJobInput


def run(job_input: IJobInput):

    counter = job_input.get_arguments().get("counter")
    job_input.execute_query(f"insert into test_table VALUES ('one', {counter})")

db92ff6e28857e7bc989b38313d4a98e8962b87f
<mask token>

<mask token>


def run(job_input: IJobInput):
    counter = job_input.get_arguments().get('counter')
    job_input.execute_query(f"insert into test_table VALUES ('one', {counter})"
        )

from vdk.api.job_input import IJobInput


def run(job_input: IJobInput):
    counter = job_input.get_arguments().get('counter')
    job_input.execute_query(f"insert into test_table VALUES ('one', {counter})"
        )

# Copyright 2021 VMware, Inc.
# SPDX-License-Identifier: Apache-2.0
from vdk.api.job_input import IJobInput


def run(job_input: IJobInput):

    counter = job_input.get_arguments().get("counter")
    job_input.execute_query(f"insert into test_table VALUES ('one', {counter})")
