diff options
author | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-06-04 16:21:35 -0700 |
---|---|---|
committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-06-04 16:27:17 -0700 |
commit | f1bd24fbe47cc0d8103ce5652b6952108de372f2 (patch) | |
tree | ea6a9c7c2fe9712e9db0c840c1dadc91da0bee26 /taskflow/conductors | |
parent | 9091a9ce96ab29182e97f975dcbf73978b5a5682 (diff) | |
download | taskflow-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.py | 6 |
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() |