summaryrefslogtreecommitdiff
path: root/taskflow/engines/worker_based/executor.py
diff options
context:
space:
mode:
authorTakashi Kajinami <tkajinam@redhat.com>2022-05-17 22:56:45 +0900
committerTakashi Kajinami <tkajinam@redhat.com>2022-05-18 16:12:37 +0900
commit44f17d005ff53008144ca7c509bcb1307d66b23f (patch)
treeb03024443b92a78f3cdacfca29f4010d24c8b685 /taskflow/engines/worker_based/executor.py
parentb5b69e8110da44a88b2260cd24ada3439f29938e (diff)
downloadtaskflow-44f17d005ff53008144ca7c509bcb1307d66b23f.tar.gz
Remove six
This library no longer supports Python 2, thus usage of six can be removed. This also removes workaround about pickle library used in Python 2 only. Change-Id: I19d298cf0f402d65f0b142dea0bf35cf992332a9
Diffstat (limited to 'taskflow/engines/worker_based/executor.py')
-rw-r--r--taskflow/engines/worker_based/executor.py3
1 files changed, 1 insertions, 2 deletions
diff --git a/taskflow/engines/worker_based/executor.py b/taskflow/engines/worker_based/executor.py
index 0215037..14139bf 100644
--- a/taskflow/engines/worker_based/executor.py
+++ b/taskflow/engines/worker_based/executor.py
@@ -18,7 +18,6 @@ import functools
import threading
from oslo_utils import timeutils
-import six
from taskflow.engines.action_engine import executor
from taskflow.engines.worker_based import dispatcher
@@ -141,7 +140,7 @@ class WorkerTaskExecutor(executor.TaskExecutor):
if not self._ongoing_requests:
return
with self._ongoing_requests_lock:
- ongoing_requests_uuids = set(six.iterkeys(self._ongoing_requests))
+ ongoing_requests_uuids = set(self._ongoing_requests.keys())
waiting_requests = {}
expired_requests = {}
for request_uuid in ongoing_requests_uuids: