`airflow.triggers.external_task`¶

Module Contents¶

`TaskStateTrigger`	Waits asynchronously for a task in a different DAG to complete for a
`DagStateTrigger`	Waits asynchronously for a DAG to complete for a specific logical date.

class airflow.triggers.external_task.TaskStateTrigger(dag_id, task_id, states, execution_dates, poll_interval=5.0)[source]¶

Waits asynchronously for a task in a different DAG to complete for a specific logical date.

Parameters

dag_id (str) – The dag_id that contains the task you want to wait for
task_id (str) – The task_id that contains the task you want to wait for. If None (default value) the sensor waits for the DAG
states (list[str]) – allowed states, default is ['success']
execution_dates (list[datetime.datetime]) –
poll_interval (float) – The time interval in seconds to check the state. The default value is 5 sec.

serialize()[source]¶

Serializes TaskStateTrigger arguments and classpath.

async run()[source]¶

Checks periodically in the database to see if the task exists, and has hit one of the states yet, or not.

count_tasks(*, session=NEW_SESSION)[source]¶

Count how many task instances in the database match our criteria.

class airflow.triggers.external_task.DagStateTrigger(dag_id, states, execution_dates, poll_interval=5.0)[source]¶

Waits asynchronously for a DAG to complete for a specific logical date.

Parameters

dag_id (str) – The dag_id that contains the task you want to wait for
states (list[str]) – allowed states, default is ['success']
execution_dates (list[datetime.datetime]) – The logical date at which DAG run.
poll_interval (float) – The time interval in seconds to check the state. The default value is 5.0 sec.

serialize()[source]¶

Serializes DagStateTrigger arguments and classpath.

async run()[source]¶

Checks periodically in the database to see if the dag run exists, and has hit one of the states yet, or not.

count_dags(*, session=NEW_SESSION)[source]¶

Count how many dag runs in the database match our criteria.