diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2019-05-14 03:50:06 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-05-14 03:50:06 -0700 |
| commit | 452ffd2e35e1d997007c01990548d4e5e3ffe268 (patch) | |
| tree | 08bee2f0bbe7efdf8eee5819fa9e3199f2143243 | |
| parent | 86f2d45ba385a780ffd8cb989ab2b3e5e4a02365 (diff) | |
| download | kafka-python-jeffwidman-patch-1.tar.gz | |
No need to cast to listjeffwidman-patch-1
`sorted` already returns a list
(squash when merging, i'm just on a different computer using web UI so can't do it here)
| -rw-r--r-- | kafka/coordinator/assignors/range.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/assignors/range.py b/kafka/coordinator/assignors/range.py index 2fa5651..397c1b7 100644 --- a/kafka/coordinator/assignors/range.py +++ b/kafka/coordinator/assignors/range.py @@ -46,7 +46,7 @@ class RangePartitionAssignor(AbstractPartitionAssignor): if partitions is None: log.warning('No partition metadata for topic %s', topic) continue - partitions = sorted(list(partitions)) + partitions = sorted(partitions) consumers_for_topic.sort() partitions_per_consumer = len(partitions) // len(consumers_for_topic) |