passionworkeer commented on issue #54254: URL: https://github.com/apache/airflow/issues/54254#issuecomment-4049751536
The implementation probably needs two changes together: (1) normalize log stream extraction across both schemas, i.e. collect from ttempts[].container.logStreamName and also flatten ttempts[].taskProperties[].containers[].logStreamName for multi-node jobs; (2) filter falsy entries before link generation, e.g. build stream_names = [name for name in stream_names if name] so [None] becomes []. I’d keep the extractor as a small helper returning a deduplicated list of valid stream names, because that makes unit tests easy: single-node with one stream, multi-node with multiple containers, mixed None/valid values, and the no-log case where the operator should skip log-link rendering instead of failing after job success. -- 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]
