dstandish commented on code in PR #67347:
URL: https://github.com/apache/airflow/pull/67347#discussion_r3319292723
##########
shared/listeners/src/airflow_shared/listeners/listener.py:
##########
@@ -17,24 +17,73 @@
# under the License.
from __future__ import annotations
+import threading
from typing import TYPE_CHECKING
import pluggy
import structlog
+from opentelemetry import trace
+from opentelemetry.trace import Status, StatusCode
if TYPE_CHECKING:
+ from opentelemetry.trace import Span
from pluggy._hooks import _HookRelay
log = structlog.get_logger(__name__)
+tracer = trace.get_tracer(__name__)
+
+# Duplicated from airflow_shared.observability.traces to avoid a
cross-shared-library
+# dependency. Must stay in sync with TASK_SPAN_DETAIL_LEVEL_KEY /
DEFAULT_TASK_SPAN_DETAIL_LEVEL there.
Review Comment:
looks like the answer is to use relative import
--
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]
