DbtCloudRunJobOperatorAsync
Astronomer ProvidersExecutes a dbt Cloud job asynchronously. Trigger the dbt cloud job via worker to dbt and with run id in response poll for the status in trigger.
Access Instructions
Install the Astronomer Providers provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
dbt_cloud_conn_idThe connection ID for connecting to dbt Cloud.
job_idThe ID of a dbt Cloud job.
account_idOptional. The ID of a dbt Cloud account.
trigger_reasonOptional Description of the reason to trigger the job. Dbt requires the trigger reason while making an API. if it is not provided uses the default reasons.
steps_overrideOptional. List of dbt commands to execute when triggering the job instead of those configured in dbt Cloud.
schema_overrideOptional. Override the destination schema in the configured target for this job.
timeoutTime in seconds to wait for a job run to reach a terminal status. Defaults to 7 days.
check_intervalTime in seconds to check on a job run’s status. Defaults to 60 seconds.
additional_run_configOptional. Any additional parameters that should be included in the API request when triggering the job.
Documentation
Executes a dbt Cloud job asynchronously. Trigger the dbt cloud job via worker to dbt and with run id in response poll for the status in trigger.
See also
For more information on sync Operator DbtCloudRunJobOperator, take a look at the guide: howto/operator:DbtCloudRunJobOperator