airflow.example_dags.plugins.event_listener
¶
Module Contents¶
Functions¶
|
This method is called when task state changes to RUNNING. |
|
This method is called when task state changes to SUCCESS. |
|
This method is called when task state changes to FAILED. |
|
This method is called when dag run state changes to SUCCESS. |
|
This method is called when dag run state changes to FAILED. |
|
This method is called when dag run state changes to RUNNING. |
- airflow.example_dags.plugins.event_listener.on_task_instance_running(previous_state, task_instance, session)[source]¶
This method is called when task state changes to RUNNING. Through callback, parameters like previous_task_state, task_instance object can be accessed. This will give more information about current task_instance that is running its dag_run, task and dag information.
- airflow.example_dags.plugins.event_listener.on_task_instance_success(previous_state, task_instance, session)[source]¶
This method is called when task state changes to SUCCESS. Through callback, parameters like previous_task_state, task_instance object can be accessed. This will give more information about current task_instance that has succeeded its dag_run, task and dag information.
- airflow.example_dags.plugins.event_listener.on_task_instance_failed(previous_state, task_instance, session)[source]¶
This method is called when task state changes to FAILED. Through callback, parameters like previous_task_state, task_instance object can be accessed. This will give more information about current task_instance that has failed its dag_run, task and dag information.
- airflow.example_dags.plugins.event_listener.on_dag_run_success(dag_run, msg)[source]¶
This method is called when dag run state changes to SUCCESS.