Exception in worker queue thread

Fix how we should not try to use the partial function for
kwargs in this case, but should just use the normal args
instead to pass in the path to the callback function.

Fixes bug 1302089

Change-Id: I98344de8d45683531e5b0bf7100e7d3c8877cbdb
This commit is contained in:
Joshua Harlow
2014-04-03 10:52:40 -07:00
committed by Thomas Goirand
parent 7f7c9285d1
commit 3af02e7c72

View File

@@ -262,9 +262,9 @@ class ZookeeperJobBoard(jobboard.JobBoard):
# This method is called from a asynchronous handler so it's
# better to exit from this quickly to allow other
# asynchronous handlers to be executed.
func = functools.partial(self._process_child, path=path)
child_proc = functools.partial(self._process_child, path)
result = self._client.get_async(path)
result.rawlink(func)
result.rawlink(child_proc)
def _format_job(self, job):
posting = {