diff options
| author | Jenkins <jenkins@review.openstack.org> | 2014-07-03 03:41:36 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2014-07-03 03:41:36 +0000 |
| commit | 3db326a68c3d6b7a614d4bbcbb149a168e5cc256 (patch) | |
| tree | 923b9fc4ffbdadec2dec8ae4b06ba74ef2db4c83 /taskflow/engines/worker_based/executor.py | |
| parent | 05fe38aa1df59ea7d8c448bd37a60c3241a3f8ad (diff) | |
| parent | d59fb4d42865a64f37680d26a593e20f74756ce1 (diff) | |
| download | taskflow-3db326a68c3d6b7a614d4bbcbb149a168e5cc256.tar.gz | |
Merge "Create a top level time type"
Diffstat (limited to 'taskflow/engines/worker_based/executor.py')
| -rw-r--r-- | taskflow/engines/worker_based/executor.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/taskflow/engines/worker_based/executor.py b/taskflow/engines/worker_based/executor.py index 35febd4..afea043 100644 --- a/taskflow/engines/worker_based/executor.py +++ b/taskflow/engines/worker_based/executor.py @@ -23,6 +23,7 @@ from taskflow.engines.worker_based import cache from taskflow.engines.worker_based import protocol as pr from taskflow.engines.worker_based import proxy from taskflow import exceptions as exc +from taskflow.types import time as tt from taskflow.utils import async_utils from taskflow.utils import misc from taskflow.utils import reflection @@ -77,7 +78,7 @@ class WorkerTaskExecutor(executor.TaskExecutorBase): self._proxy = proxy.Proxy(uuid, exchange, self._on_message, self._on_wait, **kwargs) self._proxy_thread = None - self._periodic = PeriodicWorker(misc.Timeout(pr.NOTIFY_PERIOD), + self._periodic = PeriodicWorker(tt.Timeout(pr.NOTIFY_PERIOD), [self._notify_topics]) self._periodic_thread = None |