From 99fc75c43a295c80d5290c824484c0dd315f0c69 Mon Sep 17 00:00:00 2001 From: Taybin Rutkin Date: Tue, 6 Jul 2021 17:50:27 -0400 Subject: [PATCH] actually stop lint warning on line --- faust/transport/drivers/aiokafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py index fb8050409..f2f244db9 100644 --- a/faust/transport/drivers/aiokafka.py +++ b/faust/transport/drivers/aiokafka.py @@ -723,7 +723,7 @@ 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( + tp_state = self._ensure_consumer()._fetcher._subscriptions.subscription.assignment.state_value( # noqa: E501 aiotp ) highwater = tp_state.highwater