summaryrefslogtreecommitdiff
path: root/taskflow/conductors/backends/impl_nonblocking.py
diff options
context:
space:
mode:
authorZuul <zuul@review.opendev.org>2022-06-10 01:20:55 +0000
committerGerrit Code Review <review@openstack.org>2022-06-10 01:20:55 +0000
commitc04efe3d7f0397694096575eab33c1f95edcf2f5 (patch)
treeafc2945d6b2d5ee4737e47c5f02982a6d566f18a /taskflow/conductors/backends/impl_nonblocking.py
parenta26e2d8898a2203a72adf28c8751e41450b1c020 (diff)
parent44f17d005ff53008144ca7c509bcb1307d66b23f (diff)
downloadtaskflow-c04efe3d7f0397694096575eab33c1f95edcf2f5.tar.gz
Merge "Remove six"
Diffstat (limited to 'taskflow/conductors/backends/impl_nonblocking.py')
-rw-r--r--taskflow/conductors/backends/impl_nonblocking.py3
1 files changed, 1 insertions, 2 deletions
diff --git a/taskflow/conductors/backends/impl_nonblocking.py b/taskflow/conductors/backends/impl_nonblocking.py
index 76893d7..dcdd238 100644
--- a/taskflow/conductors/backends/impl_nonblocking.py
+++ b/taskflow/conductors/backends/impl_nonblocking.py
@@ -13,7 +13,6 @@
# under the License.
import futurist
-import six
from taskflow.conductors.backends import impl_executor
from taskflow.utils import threading_utils as tu
@@ -63,7 +62,7 @@ class NonBlockingConductor(impl_executor.ExecutorConductor):
if executor_factory is None:
self._executor_factory = self._default_executor_factory
else:
- if not six.callable(executor_factory):
+ if not callable(executor_factory):
raise ValueError("Provided keyword argument 'executor_factory'"
" must be callable")
self._executor_factory = executor_factory