airflow.example_dags.plugins.event_listener

Module Contents

Functions

on_task_instance_running(previous_state, ...)

This method is called when task state changes to RUNNING.

on_task_instance_success(previous_state, ...)

This method is called when task state changes to SUCCESS.

on_task_instance_failed(previous_state, task_instance, ...)

This method is called when task state changes to FAILED.

on_dag_run_success(dag_run, msg)

This method is called when dag run state changes to SUCCESS.

on_dag_run_failed(dag_run, msg)

This method is called when dag run state changes to FAILED.

on_dag_run_running(dag_run, msg)

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.

airflow.example_dags.plugins.event_listener.on_dag_run_failed(dag_run, msg)[source]

This method is called when dag run state changes to FAILED.

airflow.example_dags.plugins.event_listener.on_dag_run_running(dag_run, msg)[source]

This method is called when dag run state changes to RUNNING.

Was this entry helpful?