diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-12 13:58:15 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-12 13:58:15 +0530 |
| commit | 28884c80f3cea53220c77a4b648488442e3900dd (patch) | |
| tree | 8452f1fa656f1a83e329468be7408e7575038c4e /kafka/util.py | |
| parent | b0c87eed088936c9ec571f789d7818bf445d47b3 (diff) | |
| download | kafka-python-28884c80f3cea53220c77a4b648488442e3900dd.tar.gz | |
Fix an issue with thread argument
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() |