summaryrefslogtreecommitdiff
path: root/taskflow/engines/worker_based/executor.py
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2014-06-10 17:04:15 -0700
committerJoshua Harlow <harlowja@gmail.com>2014-06-13 19:27:17 -0700
commitc558da07b65bebdc6940be72348d126fa1eccda6 (patch)
tree0b7ff07d7c780625e83deca607f461b21d542957 /taskflow/engines/worker_based/executor.py
parent89c4a30fd12190885991c0d6e23f0d50ef448092 (diff)
downloadtaskflow-c558da07b65bebdc6940be72348d126fa1eccda6.tar.gz
Upgrade hacking version and fix some of the issues
Update hacking to the new requirements version and fix about half of the new reported issues. The other hacking issues are for now ignored until fixed by adjusting our tox.ini file. This commit fixes the following new hacking errors: H405 - multi line docstring summary not separated with an empty line E265 - block comment should start with '# ' F402 - import 'endpoint' from line 21 shadowed by loop variable Change-Id: I6bae61591fb988cc17fa79e21cb5f1508d22781c
Diffstat (limited to 'taskflow/engines/worker_based/executor.py')
-rw-r--r--taskflow/engines/worker_based/executor.py6
1 files changed, 2 insertions, 4 deletions
diff --git a/taskflow/engines/worker_based/executor.py b/taskflow/engines/worker_based/executor.py
index 98ff3a8..37ea8bd 100644
--- a/taskflow/engines/worker_based/executor.py
+++ b/taskflow/engines/worker_based/executor.py
@@ -216,7 +216,7 @@ class WorkerTaskExecutor(executor.TaskExecutorBase):
return async_utils.wait_for_any(fs, timeout)
def start(self):
- """Start proxy thread (and associated topic notification thread)."""
+ """Starts proxy thread and associated topic notification thread."""
if not _is_alive(self._proxy_thread):
self._proxy_thread = tu.daemon_thread(self._proxy.start)
self._proxy_thread.start()
@@ -227,9 +227,7 @@ class WorkerTaskExecutor(executor.TaskExecutorBase):
self._periodic_thread.start()
def stop(self):
- """Stop proxy thread (and associated topic notification thread), so
- those threads will be gracefully terminated.
- """
+ """Stops proxy thread and associated topic notification thread."""
if self._periodic_thread is not None:
self._periodic.stop()
self._periodic_thread.join()