Skip to content

Commit ee185fe

Browse files
lint fix
1 parent fcf8c50 commit ee185fe

File tree

1 file changed

+8
-7
lines changed
  • instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka

1 file changed

+8
-7
lines changed

Diff for: instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py

+8-7
Original file line numberDiff line numberDiff line change
@@ -103,19 +103,20 @@ def instrument_consumer(consumer: Consumer, tracer_provider=None)
103103
from confluent_kafka import Consumer, Producer
104104

105105
from opentelemetry import context, propagate, trace
106-
from opentelemetry.instrumentation.confluent_kafka.package import _instruments
107-
from opentelemetry.instrumentation.confluent_kafka.utils import (
106+
from opentelemetry.instrumentation.instrumentor import BaseInstrumentor
107+
from opentelemetry.instrumentation.utils import unwrap
108+
from opentelemetry.semconv.trace import MessagingOperationValues
109+
from opentelemetry.trace import Link, SpanKind, Tracer
110+
111+
from .package import _instruments
112+
from .utils import (
108113
KafkaPropertiesExtractor,
109114
_enrich_span,
110115
_get_span_name,
111116
_kafka_getter,
112117
_kafka_setter,
113118
)
114-
from opentelemetry.instrumentation.confluent_kafka.version import __version__
115-
from opentelemetry.instrumentation.instrumentor import BaseInstrumentor
116-
from opentelemetry.instrumentation.utils import unwrap
117-
from opentelemetry.semconv.trace import MessagingOperationValues
118-
from opentelemetry.trace import Link, SpanKind, Tracer
119+
from .version import __version__
119120

120121

121122
class AutoInstrumentedProducer(Producer):

0 commit comments

Comments
 (0)