airflow.providers.standard.utils.hitl

Human-in-the-loop checks shared by HITLOperator and request_input(), and the answers a resumed task replays.

Kept apart from airflow.providers.standard.operators.hitl, which cannot be imported before Airflow 3.1, so that PythonOperator can import it on every supported Airflow version.

Classes

InputResponse

The answer to a request_input() call.

Module Contents

class airflow.providers.standard.utils.hitl.InputResponse[source]

Bases: TypedDict

The answer to a request_input() call.

chosen_options: list[str][source]
params_input: dict[str, Any][source]
responded_at: datetime.datetime[source]
responded_by_user: airflow.sdk.execution_time.hitl.HITLUser | None[source]
timedout: bool[source]

Was this entry helpful?