summaryrefslogtreecommitdiff
path: root/taskflow/conductors
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2015-06-04 16:21:35 -0700
committerJoshua Harlow <harlowja@yahoo-inc.com>2015-06-04 16:27:17 -0700
commitf1bd24fbe47cc0d8103ce5652b6952108de372f2 (patch)
treeea6a9c7c2fe9712e9db0c840c1dadc91da0bee26 /taskflow/conductors
parent9091a9ce96ab29182e97f975dcbf73978b5a5682 (diff)
downloadtaskflow-f1bd24fbe47cc0d8103ce5652b6952108de372f2.tar.gz
Remove all 'lock_utils' now that fasteners provides equivalents
Depends-On: I442249783da4a6ae10c78b95e0b279409c95d2e6 Change-Id: I877928c858e8d6176d3f01ad9de2765104acf5c3
Diffstat (limited to 'taskflow/conductors')
-rw-r--r--taskflow/conductors/base.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/taskflow/conductors/base.py b/taskflow/conductors/base.py
index 7a6b8ce..6e46fff 100644
--- a/taskflow/conductors/base.py
+++ b/taskflow/conductors/base.py
@@ -15,11 +15,11 @@
import abc
import threading
+import fasteners
import six
from taskflow import engines
from taskflow import exceptions as excp
-from taskflow.utils import lock_utils
@six.add_metaclass(abc.ABCMeta)
@@ -109,13 +109,13 @@ class Conductor(object):
# listener factories over the jobboard
return []
- @lock_utils.locked
+ @fasteners.locked
def connect(self):
"""Ensures the jobboard is connected (noop if it is already)."""
if not self._jobboard.connected:
self._jobboard.connect()
- @lock_utils.locked
+ @fasteners.locked
def close(self):
"""Closes the contained jobboard, disallowing further use."""
self._jobboard.close()