We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 539c33e commit 14a9e13Copy full SHA for 14a9e13
kafka/consumer/fetcher.py
@@ -613,7 +613,8 @@ def _fetchable_partitions(self):
613
fetchable = self._subscriptions.fetchable_partitions()
614
# do not fetch a partition if we have a pending fetch response to process
615
# use copy.copy to avoid runtimeerror on mutation from different thread
616
- discard = {fetch.topic_partition for fetch in self._completed_fetches.copy()}
+ # TODO: switch to deque.copy() with py3
617
+ discard = {fetch.topic_partition for fetch in copy.copy(self._completed_fetches)}
618
current = self._next_partition_records
619
if current:
620
discard.add(current.topic_partition)
0 commit comments