diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-05-15 13:52:59 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:49 +0300 |
| commit | 4474a50162f73aaabe770ee6dce9bd9b2110b2d5 (patch) | |
| tree | 0adaef3ebcebbfd344e153ec639cc7183fc5258d | |
| parent | a3fb3225a27ba6ca1a9fdac519c1f4257754d4eb (diff) | |
| download | kafka-python-4474a50162f73aaabe770ee6dce9bd9b2110b2d5.tar.gz | |
Async producer: py2.6 backward compatibility fix
| -rw-r--r-- | kafka/producer/base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 602e2ed..2e2f3c4 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -126,8 +126,8 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, if error_type in RETRY_REFRESH_ERROR_TYPES: client.load_metadata_for_topics() - reqs = {key: count + 1 for key, count in reqs.items() - if key in reqs_to_retry and count < retry_options.limit} + reqs = dict((key, count + 1) for (key, count) in reqs.items() + if key in reqs_to_retry and count < retry_options.limit) class Producer(object): |