Hi, I have two docker jobs like this:

@job
def dbt_transformed():
    docker_config = {
        "image": "dbt-image",
        "command": [
            "build",
            "--select",
            "tag:transformed",
        ]
    }
    docker_container_op.configured(
        docker_config,
        name="dbt_transformed_op",
    )()


@job
def dbt_transformed_other():
    docker_config = {
        "image": "dbt-image",
        "command": [
            "build",
            "--select",
            "tag:transformed_other",
        ]
    }
    docker_container_op.configured(
        docker_config,
        name="dbt_transformed_other_op",
    )()

They work, but the code is almost the same… Is there any way to do something like this?:

job_config = {
   "dbt_transformed": "tag:transformed", 
   "dbt_transformed_other": "tag:transformed_other"
}

jobs = []

for job_name, select in job_config.items():
    docker_config = {
        "image": "dbt-image",
        "command": [
            "build",
            "--select",
            select,
        ]
    }
    op = docker_container_op.configured(
        docker_config,
        name=f"{job_name}_op",
    )
    job = define_job(name, op) # function that I miss
    jobs.append(job)

I can not find a function like

define_job

to accomplish what I need Any way to define jobs not with a decorator but with a function passing a name and an op ?

You should be able to just define a simple factory function like this:

job_config = {
   "dbt_transformed": "tag:transformed", 
   "dbt_transformed_other": "tag:transformed_other"
}

jobs = []

def define_job(job_name, select):
    @job(name=job_name)
    def job_template():
        docker_config = {
        "image": "dbt-image",
        "command": [
            "build",
            "--select",
            select,
        ]
        }
        op = docker_container_op.configured(
            docker_config,
            name=f"{job_name}_op",
        )
    return job_template

for job_name, select in job_config.items():
    job = define_job(name, select)
    jobs.append(job)

Thanks! That did the trick!