github-actions[bot] opened a new pull request, #75116:
URL: https://github.com/apache/airflow/pull/75116
* Add the resume event to stored next_kwargs without decoding them
handle_event_submit only needs to add the trigger event to a task
instance's stored next_kwargs. It previously decoded the whole stored
payload, added the event and re-encoded everything, reconstructing every
stored value in the scheduler, triggerer and API server although only the
worker ever needs those objects.
Merge the serialized event into the stored serialized dict instead. Stored
values pass through untouched; payloads that are not a dict at the top
level still fail the task instance rather than resuming it. Rows still in
the legacy {"__type": "dict", "__var": ...} shape keep that shape.
Generated-by: Claude Opus 5
* Fail the task when a legacy resume event cannot be serialized
(cherry picked from commit 11174724838fd21cfe6d630d4fae9dd88c186992)
Co-authored-by: Jarek Potiuk <[email protected]>
Generated-by: Claude Opus 5
--
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]
