summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorZuul <zuul@review.openstack.org>2017-10-24 03:01:55 +0000
committerGerrit Code Review <review@openstack.org>2017-10-24 03:01:55 +0000
commite9e7337a38c579303944001cbde2f2724949f5ec (patch)
treeec42d92c79bd40962a86f7cc06f920aa927a0650
parenta121be0ac2e53ecda9f0e189646a9ee5edd39a80 (diff)
parent4bf1db9f438a8d95d007ec36be87cdfb9590f6a0 (diff)
downloadtaskflow-e9e7337a38c579303944001cbde2f2724949f5ec.tar.gz
Merge "Remove kwarg timeout in executor conductor"
-rw-r--r--taskflow/conductors/backends/impl_executor.py4
1 files changed, 1 insertions, 3 deletions
diff --git a/taskflow/conductors/backends/impl_executor.py b/taskflow/conductors/backends/impl_executor.py
index 37d7774..2dc2ddd 100644
--- a/taskflow/conductors/backends/impl_executor.py
+++ b/taskflow/conductors/backends/impl_executor.py
@@ -22,7 +22,6 @@ try:
except ImportError:
from contextlib2 import ExitStack # noqa
-from debtcollector import removals
from oslo_utils import excutils
from oslo_utils import timeutils
import six
@@ -129,8 +128,7 @@ class ExecutorConductor(base.Conductor):
raise excp.NotImplementedError("This method must be implemented but"
" it has not been")
- @removals.removed_kwarg('timeout', version="0.8", removal_version="2.0")
- def stop(self, timeout=None):
+ def stop(self):
"""Requests the conductor to stop dispatching.
This method can be used to request that a conductor stop its