astronomer.providers.core.triggers.external_task
¶
Module Contents¶
Classes¶
Waits asynchronously for a task in a different DAG to complete for a |
|
Waits asynchronously for a task in a different DAG to complete for a |
|
ExternalDeploymentTaskTrigger Inherits from HttpTrigger and make Async http call to get the deployment state |
- class astronomer.providers.core.triggers.external_task.TaskStateTrigger(dag_id, task_id, states, execution_dates, poll_interval=5.0)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
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 DAGstates (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.
- 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)¶
Count how many task instances in the database match our criteria.
- class astronomer.providers.core.triggers.external_task.DagStateTrigger(dag_id, states, execution_dates, poll_interval=5.0)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
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 – The task_id that contains the task you want to wait for. If
None
(default value) the sensor waits for the DAGstates (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.
- 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)¶
Count how many dag runs in the database match our criteria.
- class astronomer.providers.core.triggers.external_task.ExternalDeploymentTaskTrigger(endpoint, http_conn_id='http_default', method='GET', data=None, headers=None, extra_options=None, poke_interval=5.0)[source]¶
Bases:
astronomer.providers.http.triggers.http.HttpTrigger
ExternalDeploymentTaskTrigger Inherits from HttpTrigger and make Async http call to get the deployment state