o-nikolas commented on code in PR #67217:
URL: https://github.com/apache/airflow/pull/67217#discussion_r3463223889
##########
task-sdk/src/airflow/sdk/execution_time/callback_supervisor.py:
##########
@@ -227,6 +227,7 @@ def _target():
bundle = DagBundlesManager().get_bundle(
name=bundle_info.name,
version=bundle_info.version,
+ version_data=bundle_info.version_data,
Review Comment:
Good catch on both. Added version_data to the _BundleInfoLike Protocol.
For the producer-side gap (ExecuteCallback.make / prepare_callback_bundle /
CallbackRequest), I'd like to handle that in a dedicated follow-up PR rather
than scope creep this one even more.
--
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]
