astronomer.providers.dbt.cloud.triggers.dbt

Module Contents

Classes

DbtCloudRunJobTrigger

This class is deprecated and will be removed in 2.0.0.
class astronomer.providers.dbt.cloud.triggers.dbt.DbtCloudRunJobTrigger(conn_id, run_id, end_time, poll_interval, account_id)[source]

Bases: airflow.triggers.base.BaseTrigger

This class is deprecated and will be removed in 2.0.0. Use :class: ~airflow.providers.dbt.triggers.dbt.DbtCloudRunJobTrigger instead.

serialize()[source]

Serializes DbtCloudRunJobTrigger arguments and classpath.

async run()[source]

Make async connection to Dbt, polls for the pipeline run status

async is_still_running(hook)[source]

Async function to check whether the job is submitted via async API is in running state and returns True if it is still running else return False