airflow.providers.common.ai.plugins.hitl_review¶

Attributes¶

Register the HITL Review REST API + chat UI on the Airflow API server.

`health`()	Liveness check.
`find_session`(db, dag_id, task_id, run_id, map_index)	Find the feedback session for a specific task instance.
`submit_feedback`(body, db, dag_id, task_id, run_id, ...)	Request changes — provide human feedback for the LLM.
`approve_session`(db, dag_id, task_id, run_id, map_index)	Approve the current output.
`reject_session`(db, dag_id, task_id, run_id, map_index)	Reject the output.

async airflow.providers.common.ai.plugins.hitl_review.health()[source]¶

Liveness check.

async airflow.providers.common.ai.plugins.hitl_review.find_session(db, dag_id, task_id, run_id, map_index)[source]¶

Find the feedback session for a specific task instance.

async airflow.providers.common.ai.plugins.hitl_review.submit_feedback(body, db, dag_id, task_id, run_id, map_index)[source]¶

Request changes — provide human feedback for the LLM.

async airflow.providers.common.ai.plugins.hitl_review.approve_session(db, dag_id, task_id, run_id, map_index)[source]¶

Approve the current output.

async airflow.providers.common.ai.plugins.hitl_review.reject_session(db, dag_id, task_id, run_id, map_index)[source]¶

Reject the output.

class airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin[source]¶

Bases: airflow.plugins_manager.AirflowPlugin

Register the HITL Review REST API + chat UI on the Airflow API server.