From 28884c80f3cea53220c77a4b648488442e3900dd Mon Sep 17 00:00:00 2001
From: Mahendra M <mahendra.m@gmail.com>
Date: Wed, 12 Jun 2013 13:58:15 +0530
Subject: Fix an issue with thread argument

---
 kafka/util.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'kafka/util.py')

diff --git a/kafka/util.py b/kafka/util.py
index 11db747..11178f5 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -108,7 +108,7 @@ class ReentrantTimer(object):
             self.stop()
 
         self.active = Event()
-        self.thread = Thread(target=self._timer, args=(self.active))
+        self.thread = Thread(target=self._timer, args=(self.active,))
         self.thread.daemon = True  # So the app exits when main thread exits
         self.thread.start()
 
-- 
cgit v1.2.1