shivaam opened a new pull request, #63657:
URL: https://github.com/apache/airflow/pull/63657
Enable the ECS executor to handle callback workloads (e.g., deadline alerts)
alongside regular task workloads. Callbacks are serialized, dispatched to ECS
containers, and tracked through the same lifecycle as tasks.
Changes:
- Add supports_callbacks flag and queued_callbacks dict
- Widen key types from TaskInstanceKey to WorkloadKey
- Branch on ExecuteTask vs ExecuteCallback in queue_workload and
_process_workloads
- Guard log_task_event calls for task-only keys
- Use cast() instead of type:ignore for success/fail/running_state
- Add DAG bundle setup in execute_workload.py for container-side callback
execution
- Add AIRFLOW_V_3_2_PLUS version gate to version_compat.py
<!-- SPDX-License-Identifier: Apache-2.0
https://www.apache.org/licenses/LICENSE-2.0 -->
* related: #62887
---
##### Was generative AI tooling used to co-author this PR?
- [x] Yes (Claude code)
--
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]
