Skip to content

Commit

Permalink
actually stop lint warning on line
Browse files Browse the repository at this point in the history
  • Loading branch information
Taybin Rutkin committed Jul 6, 2021
1 parent f10f284 commit 99fc75c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion faust/transport/drivers/aiokafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 99fc75c

Please sign in to comment.