From 6cb67f1d5ae7bfac7b29d78fb496c6eb082affcf Mon Sep 17 00:00:00 2001 From: William Barnhart Date: Fri, 17 Jul 2026 12:39:14 +0000 Subject: [PATCH] Remove dead opentracing reference from confluent driver ConfluentConsumerThread carried a commented-out '# _pending_rebalancing_spans: Deque[opentracing.Span]' attribute, copied from the aiokafka driver where it held real spans. The confluent driver never used it and does not import opentracing, so drop the stale comment -- the file now has no opentracing references at all. --- faust/transport/drivers/confluent.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/faust/transport/drivers/confluent.py b/faust/transport/drivers/confluent.py index 2573a1545..19b4dd708 100644 --- a/faust/transport/drivers/confluent.py +++ b/faust/transport/drivers/confluent.py @@ -208,8 +208,6 @@ class ConfluentConsumerThread(ConsumerThread): _consumer: Optional[AsyncConsumer] = None _assigned: bool = False - # _pending_rebalancing_spans: Deque[opentracing.Span] - tp_last_committed_at: MutableMapping[TP, float] time_started: float