diff options
Diffstat (limited to 'kafka/util.py')
| -rw-r--r-- | kafka/util.py | 2 |
1 files changed, 1 insertions, 1 deletions
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() |