diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-06-18 15:48:11 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@gmail.com> | 2015-06-21 09:39:12 -0700 |
| commit | 543cf78a6f26fe4929b53a7bfb9cbdc5f2624fbd (patch) | |
| tree | af972ea24abcbd9c2ccbbad011a57dd230a419f3 /taskflow/engines/worker_based/proxy.py | |
| parent | caf37be3456dd3a0a03624afc8c25bcd20459e02 (diff) | |
| download | taskflow-543cf78a6f26fe4929b53a7bfb9cbdc5f2624fbd.tar.gz | |
Remove 2.6 classifier + 2.6 compatibility code
Fixes bug 1445827
Depends-On: I02e3c9aacef0b295a2f823a5cbaf11768a90cb82
Change-Id: I1db681803598ac1bc917fd74a99458bc61edf3f1
Diffstat (limited to 'taskflow/engines/worker_based/proxy.py')
| -rw-r--r-- | taskflow/engines/worker_based/proxy.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/taskflow/engines/worker_based/proxy.py b/taskflow/engines/worker_based/proxy.py index e9d2ec2..386e377 100644 --- a/taskflow/engines/worker_based/proxy.py +++ b/taskflow/engines/worker_based/proxy.py @@ -15,6 +15,7 @@ # under the License. import collections +import threading import kombu from kombu import exceptions as kombu_exceptions @@ -22,7 +23,6 @@ import six from taskflow.engines.worker_based import dispatcher from taskflow import logging -from taskflow.utils import threading_utils LOG = logging.getLogger(__name__) @@ -75,7 +75,7 @@ class Proxy(object): self._topic = topic self._exchange_name = exchange self._on_wait = on_wait - self._running = threading_utils.Event() + self._running = threading.Event() self._dispatcher = dispatcher.TypeDispatcher( # NOTE(skudriashev): Process all incoming messages only if proxy is # running, otherwise requeue them. |