diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2014-06-10 17:04:15 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@gmail.com> | 2014-06-13 19:27:17 -0700 |
| commit | c558da07b65bebdc6940be72348d126fa1eccda6 (patch) | |
| tree | 0b7ff07d7c780625e83deca607f461b21d542957 /taskflow/engines/worker_based/executor.py | |
| parent | 89c4a30fd12190885991c0d6e23f0d50ef448092 (diff) | |
| download | taskflow-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.py | 6 |
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() |
