Async producer: py2.6 backward compatibility fix

dpkp · May 15, 2015 · 93ef46d · 93ef46d
1 parent 4c65bfb
commit 93ef46d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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):