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
parent 7b54ac40de
commit 11ae7f64fb

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 = {