[GH] (airflow/feature/ecs-executor-callback): Workflow run "Tests" is working again!

2026-05-02 Thread GitBox


The GitHub Actions job "Tests" on airflow.git/feature/ecs-executor-callback has 
succeeded.
Run started by GitHub user shivaam (triggered by shivaam).

Head commit for run:
08bb01a9d453c50ef9ea2d4767c475c244a88ae6 / Shivam Rastogi 
<[email protected]>
Rename task-named methods/attrs and fix older-Airflow compat

Renames (mirrors the merged Lambda callback PR — straight rename,
no shim, executor-internal surface):
  sync_running_tasks -> sync_running_workloads
  attempt_task_runs  -> attempt_workload_runs
  pending_tasks (attr)   -> pending_workloads
  __update_running_task  -> __update_running_workload
  __handle_failed_task   -> __handle_failed_workload

Fix CI on older Airflow compat tests:
- Restore queue_workload() override. Airflow 3.3+ BaseExecutor routes
  ExecuteCallback natively, but pre-3.3 raises ValueError for anything
  not ExecuteTask. Override works across versions.
- Import AIRFLOW_V_3_3_PLUS from tests_common (main bumped to 3.3).
  check-airflow-v-imports-in-tests hook disallows provider-internal
  version_compat imports from test files.

Report URL: https://github.com/apache/airflow/actions/runs/25264043827

With regards,
GitHub Actions via GitBox


-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[GH] (airflow/feature/ecs-executor-callback): Workflow run "Tests" is working again!

2026-03-15 Thread GitBox


The GitHub Actions job "Tests" on airflow.git/feature/ecs-executor-callback has 
succeeded.
Run started by GitHub user shivaam (triggered by shivaam).

Head commit for run:
6ac263415fc25395c0fc1556d8592e9d83f5db03 / Shivam Rastogi 
<[email protected]>
Add ExecuteCallback support to AWS ECS Executor

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

Report URL: https://github.com/apache/airflow/actions/runs/23119686616

With regards,
GitHub Actions via GitBox


-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[GH] (airflow/feature/ecs-executor-callback): Workflow run "Tests" is working again!

2026-03-15 Thread GitBox


The GitHub Actions job "Tests" on airflow.git/feature/ecs-executor-callback has 
succeeded.
Run started by GitHub user shivaam (triggered by shivaam).

Head commit for run:
6ac263415fc25395c0fc1556d8592e9d83f5db03 / Shivam Rastogi 
<[email protected]>
Add ExecuteCallback support to AWS ECS Executor

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

Report URL: https://github.com/apache/airflow/actions/runs/23116837406

With regards,
GitHub Actions via GitBox


-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]