amoghrajesh commented on code in PR #60826:
URL: https://github.com/apache/airflow/pull/60826#discussion_r2711151509
##########
task-sdk/src/airflow/sdk/log.py:
##########
@@ -33,13 +33,21 @@
if TYPE_CHECKING:
from structlog.typing import EventDict, FilteringBoundLogger, Processor
- from airflow.logging_config import RemoteLogIO
+ from airflow.sdk._shared.logging.remote import RemoteLogIO
from airflow.sdk.types import Logger, RuntimeTaskInstanceProtocol as
RuntimeTI
from airflow.sdk._shared.secrets_masker import redact
+class _ActiveLoggingConfig:
+ """Internal class to track active logging configuration."""
+
+ logging_config_loaded = False
+ remote_task_log: RemoteLogIO | None = None
+ default_remote_conn_id: str | None = None
+
Review Comment:
dataclass might require it to have an instance(likely global, like
supervisor_comms?)
--
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]
