This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a commit to branch v3-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-3-test by this push:
new da29b1ad659 [v3-3-test] Document the 409 from XCom create and drop a
duplicated condition (#70992) (#71128)
da29b1ad659 is described below
commit da29b1ad65901a69af07d20fc0886d861620a9f7
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Aug 5 13:40:09 2026 +0530
[v3-3-test] Document the 409 from XCom create and drop a duplicated
condition (#70992) (#71128)
(cherry picked from commit 64683c9c84e7d60b4572e2dd441231eeb82f9d41)
Co-authored-by: Jyun-An Chen <[email protected]>
Co-authored-by: Rahul Vats <[email protected]>
---
.../api_fastapi/core_api/openapi/v2-rest-api-generated.yaml | 6 ++++++
.../src/airflow/api_fastapi/core_api/routes/public/xcom.py | 8 ++++----
airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts | 1 +
airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts | 4 ++++
4 files changed, 15 insertions(+), 4 deletions(-)
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
b/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
index 81c7424596a..34068eab85b 100644
---
a/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
+++
b/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
@@ -6858,6 +6858,12 @@ paths:
schema:
$ref: '#/components/schemas/HTTPExceptionResponse'
description: Not Found
+ '409':
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/HTTPExceptionResponse'
+ description: Conflict
'422':
description: Validation Error
content:
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
index 13c7f78ed28..40bb97cfc9f 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/xcom.py
@@ -237,6 +237,7 @@ def get_xcom_entries(
[
status.HTTP_400_BAD_REQUEST,
status.HTTP_404_NOT_FOUND,
+ status.HTTP_409_CONFLICT,
]
),
dependencies=[
@@ -269,10 +270,9 @@ def create_xcom_entry(
# Validate Dag Run ID
if not dag_run:
- if not dag_run:
- raise HTTPException(
- status.HTTP_404_NOT_FOUND, f"Dag Run with ID: `{dag_run_id}`
not found for dag: `{dag_id}`"
- )
+ raise HTTPException(
+ status.HTTP_404_NOT_FOUND, f"Dag Run with ID: `{dag_run_id}` not
found for dag: `{dag_id}`"
+ )
# Check existing XCom
already_existing_query = XComModel.get_many(
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
b/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
index 46d173a3c18..6a55c5871c5 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
@@ -4140,6 +4140,7 @@ export class XcomService {
401: 'Unauthorized',
403: 'Forbidden',
404: 'Not Found',
+ 409: 'Conflict',
422: 'Validation Error'
}
});
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
b/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
index dd9dd4326c6..975c7cc99bc 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
@@ -7757,6 +7757,10 @@ export type $OpenApiTs = {
* Not Found
*/
404: HTTPExceptionResponse;
+ /**
+ * Conflict
+ */
+ 409: HTTPExceptionResponse;
/**
* Validation Error
*/
