Skip to content

Commit

Permalink
redo linty linty
Browse files Browse the repository at this point in the history
  • Loading branch information
rjduffner committed Jul 31, 2024
1 parent 4cb7fe0 commit f8b7762
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ def consume_hook(span, record, args, kwargs):
from opentelemetry.instrumentation.kafka.package import (
_instruments,
_instruments_kafka_python,
_instruments_kafka_python_ng
_instruments_kafka_python_ng,
)
from opentelemetry.instrumentation.kafka.utils import _wrap_next, _wrap_send
from opentelemetry.instrumentation.kafka.version import __version__
Expand Down Expand Up @@ -145,4 +145,4 @@ def _instrument(self, **kwargs):

def _uninstrument(self, **kwargs):
unwrap(kafka.KafkaProducer, "send")
unwrap(kafka.KafkaConsumer, "__next__")#
unwrap(kafka.KafkaConsumer, "__next__")

0 comments on commit f8b7762

Please sign in to comment.