uranusjr commented on code in PR #64577:
URL: https://github.com/apache/airflow/pull/64577#discussion_r3408764328
##########
airflow-core/src/airflow/api_fastapi/core_api/routes/public/dag_run.py:
##########
@@ -548,17 +548,18 @@ def wait_dag_run_until_finished(
] = None,
):
"Wait for a dag run until it finishes, and return its result(s)."
- if result_task_ids:
- if not get_auth_manager().is_authorized_dag(
- method="GET",
- access_entity=DagAccessEntity.XCOM,
- details=DagDetails(id=dag_id),
- user=user,
- ):
+ if not get_auth_manager().is_authorized_dag(
+ method="GET",
+ access_entity=DagAccessEntity.XCOM,
+ details=DagDetails(id=dag_id),
+ user=user,
+ ):
+ if result_task_ids:
raise HTTPException(
status.HTTP_403_FORBIDDEN,
"User is not authorized to read XCom data for this DAG",
)
+ result_task_ids = [] # Explicitly not returning any XCom results.
Review Comment:
Fixed in DagRunWaiter.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
