Lee-W commented on code in PR #66571:
URL: https://github.com/apache/airflow/pull/66571#discussion_r3257096076
##########
task-sdk/src/airflow/sdk/log.py:
##########
@@ -226,20 +226,42 @@ def relative_path_from_logger(logger) -> Path | None:
def upload_to_remote(logger: FilteringBoundLogger, ti: RuntimeTI):
raw_logger = getattr(logger, "_logger")
+ # Dedicated logger for remote-upload visibility — operators relying on
+ # remote log handlers need a way to see when those handlers fail to load
+ # or fail to upload. The default behaviour was to silently fall through.
+ upload_log = structlog.get_logger("airflow.logging.remote")
handler = load_remote_log_handler()
if not handler:
+ upload_log.warning(
+ "remote_log_handler_unavailable",
+ ti_id=str(getattr(ti, "id", None)),
Review Comment:
`ti.id` is there. Or are we doing this for another backward compat?
```suggestion
ti_id=str(ti.id),
```
--
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]
