This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 6648658fbe6d9b62b50192946bb190144bf77c8e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 9 22:52:10 2025 +0000
[v3-1-test] Don't depend upon FastAPI inside Task-SDK client (#59250)
(#59257)
This annotation did nothing, and it just slows down imports.
(cherry picked from commit 740da666b58a730015b7f2e39a3cd42fc2e881b5)
Co-authored-by: Ash Berlin-Taylor <[email protected]>
---
task-sdk/src/airflow/sdk/execution_time/comms.py | 24 +-----------------------
1 file changed, 1 insertion(+), 23 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/execution_time/comms.py
b/task-sdk/src/airflow/sdk/execution_time/comms.py
index fe6435ca7f8..dcf7ea30d8a 100644
--- a/task-sdk/src/airflow/sdk/execution_time/comms.py
+++ b/task-sdk/src/airflow/sdk/execution_time/comms.py
@@ -60,7 +60,6 @@ from uuid import UUID
import attrs
import msgspec
import structlog
-from fastapi import Body
from pydantic import AwareDatetime, BaseModel, ConfigDict, Field, JsonValue,
TypeAdapter, field_serializer
from airflow.sdk.api.datamodels._generated import (
@@ -728,28 +727,7 @@ class GetXComSequenceSlice(BaseModel):
class SetXCom(BaseModel):
key: str
- value: Annotated[
- # JsonValue can handle non JSON stringified dicts, lists and strings,
which is better
- # for the task intuitibe to send to the supervisor
- JsonValue,
- Body(
- description="A JSON-formatted string representing the value to set
for the XCom.",
- openapi_examples={
- "simple_value": {
- "summary": "Simple value",
- "value": "value1",
- },
- "dict_value": {
- "summary": "Dictionary value",
- "value": {"key2": "value2"},
- },
- "list_value": {
- "summary": "List value",
- "value": ["value1"],
- },
- },
- ),
- ]
+ value: JsonValue
dag_id: str
run_id: str
task_id: str
