amoghrajesh commented on code in PR #59711:
URL: https://github.com/apache/airflow/pull/59711#discussion_r2643023418
##########
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/taskinstance.py:
##########
@@ -139,7 +139,7 @@ class TIDeferredStatePayload(StrictBaseModel):
trigger_timeout: timedelta | None = None
next_method: str
"""The name of the method on the operator to call in the worker after the
trigger has fired."""
- next_kwargs: Annotated[dict[str, Any], Field(default_factory=dict)]
+ next_kwargs: Annotated[JsonValue, Field(default_factory=dict)]
Review Comment:
I gave this some thought and why I think no cadwyn migration is needed here
is because the change from `dict[str, Any]` to `JsonValue` is essentially
widening the acceptable types, not restricting them and hence old clients
sending `dict[str, Any]` will still validate because dicts are valid
`JsonValue` and also sending a valid `JsonValue` to old client with `dict[str,
Any]` would still validate fine.
--
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]
