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,

Reply via email to