ksharlandjiev opened a new pull request, #60978: URL: https://github.com/apache/airflow/pull/60978
## Problem When SsmRunCommandOperator runs in deferrable mode and a command exits with a non-zero code, the trigger was raising an exception instead of yielding a TriggerEvent. This caused: - Trigger failures without sending events to the operator - Inability to capture exit codes for workflow routing - Task retry failures with the same error - Inconsistent behavior between deferrable and synchronous modes This fix changes the trigger to yield failure events instead of raising exceptions for command-level failures (non-zero exit codes), while still raising exceptions for AWS-level failures (Cancelled, TimedOut, Cancelling). ## Changes - Modified SsmRunCommandTrigger.run() to yield failure events with detailed information (exit code, status, instance ID, message) - Enhanced SsmRunCommandOperator.execute_complete() to handle failure events and raise RuntimeError with all details - Fixed status_queries from ["status"] to ["Status"] to properly display command status in logs The fix enables proper exit code capture in deferrable mode, allowing for workflow routing based on command exit codes while maintaining the fail_on_nonzero_exit parameter behavior. -- 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]
