airflow.providers.standard.example_dags.example_hitl_operator¶

Attributes¶

`hitl_request_callback`
`hitl_success_callback`
`hitl_failure_callback`
`wait_for_input`

Classes¶

LocalLogNotifier

Simple notifier to demonstrate HITL notification without setup any connection.

Module Contents¶

class airflow.providers.standard.example_dags.example_hitl_operator.LocalLogNotifier(message)[source]¶

Bases: airflow.sdk.bases.notifier.BaseNotifier

Simple notifier to demonstrate HITL notification without setup any connection.

template_fields = ('message',)[source]¶

message[source]¶

notify(context)[source]¶

Send a notification (sync).

Implementing this is a requirement for running this notifier in the Dag processor, which is where the on_success_callback and on_failure_callback run.

Parameters:: context (airflow.providers.common.compat.sdk.Context) – The airflow context

airflow.providers.standard.example_dags.example_hitl_operator.hitl_request_callback[source]¶

airflow.providers.standard.example_dags.example_hitl_operator.hitl_success_callback[source]¶

airflow.providers.standard.example_dags.example_hitl_operator.hitl_failure_callback[source]¶

airflow.providers.standard.example_dags.example_hitl_operator.wait_for_input[source]¶