antonio-mello-ai opened a new pull request, #63476: URL: https://github.com/apache/airflow/pull/63476
## Summary - Fix `get_job_all_awslogs_info()` to extract log stream names from both single-node (`attempts[].container.logStreamName`) and multi-node (`attempts[].taskProperties[].containers[].logStreamName`) AWS Batch job schemas - Filter out `None` values that previously bypassed the `if not stream_names:` guard, causing `TypeError` in `urllib.parse.quote_plus()` downstream ## Root Cause Multi-node AWS Batch jobs return log stream names under `attempts[].taskProperties[].containers[].logStreamName`, not the single-node path `attempts[].container.logStreamName`. The existing code only checked the single-node path, producing `stream_names = [None]` for multi-node jobs. Since `[None]` is truthy, it passed the emptiness guard and propagated `None` downstream. ## Test Plan - [x] New test: multi-node job with `taskProperties` schema extracts stream names correctly - [x] New test: multi-node job with no `logStreamName` in `container` falls through to warning path - [x] All 41 tests pass (39 existing + 2 new) - [x] All pre-commit hooks pass (`prek`) Closes #54254 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.6 <[email protected]> -- 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]
