airflow.example_dags.plugins.event_listener¶

函数¶

`on_task_instance_running`(previous_state, task_instance)	当任务状态变为 RUNNING 时调用。
`on_task_instance_success`(previous_state, task_instance)	当任务状态变为 SUCCESS 时调用。
`on_task_instance_failed`(previous_state, task_instance, ...)	当任务状态变为 FAILED 时调用。
`on_dag_run_success`(dag_run, msg)	当 DAG 运行状态变为 SUCCESS 时调用此方法。
`on_dag_run_failed`(dag_run, msg)	当 DAG 运行状态变为 FAILED 时调用此方法。
`on_dag_run_running`(dag_run, msg)	当 DAG 运行状态变为 RUNNING 时调用此方法。

airflow.example_dags.plugins.event_listener.on_task_instance_running(previous_state, task_instance)[source]¶

当任务状态变为 RUNNING 时调用。

previous_task_state 和 task_instance 对象可用于获取关于当前正在运行的任务实例、其 dag_run、任务和 dag 信息的更多细节。

airflow.example_dags.plugins.event_listener.on_task_instance_success(previous_state, task_instance)[source]¶

当任务状态变为 SUCCESS 时调用。

previous_task_state 和 task_instance 对象可用于获取关于当前已成功的任务实例、其 dag_run、任务和 dag 信息的更多细节。

在大多数情况下提供一个 RuntimeTaskInstance，除非任务状态变化是通过 API 触发的。在这种情况下，将提供 API 服务器上可用的 TaskInstance。

airflow.example_dags.plugins.event_listener.on_task_instance_failed(previous_state, task_instance, error)[source]¶

当任务状态变为 FAILED 时调用。

previous_task_state、task_instance 对象和 error 可用于获取关于当前已失败的任务实例、其 dag_run、任务和 dag 信息的更多细节。

在大多数情况下提供一个 RuntimeTaskInstance，除非任务状态变化是通过 API 触发的。在这种情况下，将提供 API 服务器上可用的 TaskInstance。

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

当 DAG 运行状态变为 SUCCESS 时调用此方法。

当 DAG 运行状态变为 SUCCESS 时调用此方法。

当 DAG 运行状态变为 FAILED 时调用此方法。

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

当 DAG 运行状态变为 RUNNING 时调用此方法。