From 11ae7f64fbb183ce32c9e3790dd39dc0a7c66a9a Mon Sep 17 00:00:00 2001 From: Joshua Harlow Date: Thu, 3 Apr 2014 10:52:40 -0700 Subject: [PATCH] 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 --- taskflow/jobs/backends/impl_zookeeper.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/taskflow/jobs/backends/impl_zookeeper.py b/taskflow/jobs/backends/impl_zookeeper.py index a8c4577d..38b5b990 100644 --- a/taskflow/jobs/backends/impl_zookeeper.py +++ b/taskflow/jobs/backends/impl_zookeeper.py @@ -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 = {