Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

In prefect, I am using prefect’s DBT cloud integration. How do I make prefect trigger a job that provides *variables* to the dbt job? Like this

```dbt run --vars '{"key": "value"}'```
Sorry for the basic question - I for some reason haven’t been able to find this in the docs.

My code so far:

```from prefect import flow

from prefect_dbt.cloud import DbtCloudCredentials
from prefect_dbt.cloud import DbtCloudJob
from prefect_dbt.cloud.models import TriggerJobRunOptions
from <http://prefect_dbt.cloud.jobs|prefect_dbt.cloud.jobs> import trigger_dbt_cloud_job_run_and_wait_for_completion

@flow(log_prints=True)
def trigger_dbt():
    dbt_cloud_job = DbtCloudJob.load('dbt-cloud-job-run-all-models')
    dbt_cloud_credentials = DbtCloudCredentials.load('dbt-cloud-credentials')

    run_result = trigger_dbt_cloud_job_run_and_wait_for_completion(
        dbt_cloud_credentials=dbt_cloud_credentials,
        job_id=dbt_cloud_job.job_id
    )

    print(run_result)

trigger_dbt()```

Figured it out :tada:

`steps_override` was the key

```from prefect import flow

from prefect_dbt.cloud import DbtCloudCredentials
from prefect_dbt.cloud import DbtCloudJob
from prefect_dbt.cloud.models import TriggerJobRunOptions
from <http://prefect_dbt.cloud.jobs|prefect_dbt.cloud.jobs> import trigger_dbt_cloud_job_run_and_wait_for_completion

@flow(log_prints=True)
def trigger_dbt():
    dbt_cloud_job = DbtCloudJob.load('dbt-cloud-job-run-all-models')
    dbt_cloud_credentials = DbtCloudCredentials.load('dbt-cloud-credentials')

    run_result = trigger_dbt_cloud_job_run_and_wait_for_completion(
        dbt_cloud_credentials=dbt_cloud_credentials,
        job_id=dbt_cloud_job.job_id,
        trigger_job_run_options=TriggerJobRunOptions(
            steps_override=[
                """dbt build --vars '{\"example_variable\": 1234}'"""
            ],
        ),
    )

    print(run_result)

trigger_dbt()```

thanks for sharing <@U05P6PFP6S1> - glad you figured it out