TaskStateTrigger

Astronomer ProvidersCertified

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

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

dag_idThe dag_id that contains the task you want to wait for
task_idThe task_id that contains the task you want to wait for. If None (default value) the sensor waits for the DAG
statesallowed states, default is ['success']
execution_dates
poll_intervalThe time interval in seconds to check the state. The default value is 5 sec.

Documentation

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

Was this page helpful?