openstack/deb-python-kafka
Code Issues Proposed changes

Fix an issue with thread argument

Browse Source
This commit is contained in:
Mahendra M
2013-06-12 13:58:15 +05:30
parent b0c87eed08
commit 28884c80f3
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/util.py
View File

@@ -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()