fix lint warning

faust-streaming · Jul 6, 2021 · e80829c · e80829c
1 parent ed06ecc
commit e80829c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py
@@ -723,7 +723,9 @@ def verify_event_path(self, now: float, tp: TP) -> None:
 
         if monitor is not None:  # need for .stream_inbound_time
             aiotp = TopicPartition(tp.topic, tp.partition)
-            tp_state = self._ensure_consumer()._fetcher._subscriptions.subscription.assignment.state_value(aiotp)
+            tp_state = self._ensure_consumer()._fetcher._subscriptions.subscription.assignment.state_value(
+                aiotp
+            )
             highwater = tp_state.highwater
             committed_offset = tp_state.position
             has_acks = acks_enabled_for(tp.topic)