This is an automated email from the ASF dual-hosted git repository.
gopidesu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 9fd607d3e52 Fix Common AI HITL review write endpoints forbidden errors
(#64550)
9fd607d3e52 is described below
commit 9fd607d3e525586bc3968552a24d1c1fe783729a
Author: GPK <[email protected]>
AuthorDate: Tue Mar 31 22:45:49 2026 +0100
Fix Common AI HITL review write endpoints forbidden errors (#64550)
---
.../ai/src/airflow/providers/common/ai/plugins/hitl_review.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/providers/common/ai/src/airflow/providers/common/ai/plugins/hitl_review.py
b/providers/common/ai/src/airflow/providers/common/ai/plugins/hitl_review.py
index 02d43c511f9..e870588f793 100644
--- a/providers/common/ai/src/airflow/providers/common/ai/plugins/hitl_review.py
+++ b/providers/common/ai/src/airflow/providers/common/ai/plugins/hitl_review.py
@@ -284,7 +284,7 @@ async def find_session(
@hitl_review_app.post(
"/sessions/feedback",
response_model=HITLReviewResponse,
- dependencies=[Depends(requires_access_dag(method="POST",
access_entity=DagAccessEntity.HITL_DETAIL))],
+ dependencies=[Depends(requires_access_dag(method="PUT",
access_entity=DagAccessEntity.HITL_DETAIL))],
)
async def submit_feedback(
body: HumanFeedbackRequest,
@@ -365,7 +365,7 @@ async def submit_feedback(
@hitl_review_app.post(
"/sessions/approve",
response_model=HITLReviewResponse,
- dependencies=[Depends(requires_access_dag(method="POST",
access_entity=DagAccessEntity.HITL_DETAIL))],
+ dependencies=[Depends(requires_access_dag(method="PUT",
access_entity=DagAccessEntity.HITL_DETAIL))],
)
async def approve_session(
db: SessionDep,
@@ -430,7 +430,7 @@ async def approve_session(
@hitl_review_app.post(
"/sessions/reject",
response_model=HITLReviewResponse,
- dependencies=[Depends(requires_access_dag(method="POST",
access_entity=DagAccessEntity.HITL_DETAIL))],
+ dependencies=[Depends(requires_access_dag(method="PUT",
access_entity=DagAccessEntity.HITL_DETAIL))],
)
async def reject_session(
db: SessionDep,