isaiahiruoha opened a new pull request, #52121: URL: https://github.com/apache/airflow/pull/52121
--- Added Task SDK support for AWS BatchExecutor to enable compatibility with Airflow 3.0+. The AWS BatchExecutor lacked support for handling Task SDK workloads, which has already been supported in the AWS ECSExecutor, changes were made to add this functionality. This meant the executor couldn't properly function with the latest Airflow architecture. **Changes:** - Implemented handling for `ExecuteTask` workloads in queue_workload method - Added _process_workloads method to properly process Task SDK workloads - Modified execute_async to handle cases where a workload object is passed instead of a direct command - Added serialization logic to convert workloads to JSON for execution in AWS Batch containers - Added new test case to verify Task SDK integration works correctly **Testing:** - Added unit test to verify proper handling of Task SDK workloads - Successfully locally ran system tests with the updated executor --- -- 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]
