The GitHub Actions job "Check newsfragment PR number" on airflow.git/fix/glue-deferrable-verbose-56535 has succeeded. Run started by GitHub user shivaam (triggered by shivaam).
Head commit for run: 945c8a377bf701f452facf8eb3b7aa59a22d3ae8 / Shivam Rastogi <[email protected]> fix(glue): Fix verbose CloudWatch log streaming for deferrable GlueJobOperator When using GlueJobOperator with deferrable=True and verbose=True, CloudWatch logs were silently ignored because the trigger inherited the base waiter's run() method which only polls job status. This adds a run() override and _forward_logs() helper to GlueJobCompleteTrigger that streams logs from both output and error CloudWatch log groups, matching the format used by the synchronous path. Key changes: - Extract get_glue_log_group_names() and format_glue_logs() as shared helpers in hooks/glue.py to eliminate sync/async duplication - Override run() in GlueJobCompleteTrigger for verbose log streaming - Yield TriggerEvent with error status on failure (matching base class pattern) instead of raising AirflowException in the triggerer process - Add tests for verbose success, failure, max attempts, pagination, ResourceNotFoundException, and no-new-events scenarios closes: #56535 Report URL: https://github.com/apache/airflow/actions/runs/23675374485 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
