diff options
| author | Jenkins <jenkins@review.openstack.org> | 2015-06-06 18:09:02 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2015-06-06 18:09:02 +0000 |
| commit | 1fb5e7a95aa0fefcb57a075ff8e7eda6c64646a5 (patch) | |
| tree | 03881952107bf27c9dfb5adbec4ff6107e75cad5 /taskflow/utils/misc.py | |
| parent | 337444ea1362b7d5c8bb99879e9f1c15fb308ef1 (diff) | |
| parent | 4fc6b612e00cfe549419ede223b8711e2be4d653 (diff) | |
| download | taskflow-1fb5e7a95aa0fefcb57a075ff8e7eda6c64646a5.tar.gz | |
Merge "Remove listener stack and replace with exit stack"
Diffstat (limited to 'taskflow/utils/misc.py')
| -rw-r--r-- | taskflow/utils/misc.py | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/taskflow/utils/misc.py b/taskflow/utils/misc.py index 005f394..c097bbe 100644 --- a/taskflow/utils/misc.py +++ b/taskflow/utils/misc.py @@ -449,38 +449,6 @@ def get_duplicate_keys(iterable, key=None): return duplicates -class ListenerStack(object): - """Listeners that are deregistered on context manager exit. - - TODO(harlowja): replace this with ``contextlib.ExitStack`` or equivalent - in the future (that code is in python3.2+ and in a few backports that - provide nearly equivalent functionality). When/if - https://review.openstack.org/#/c/164222/ merges we should be able to - remove this since listeners are already context managers. - """ - - def __init__(self, log): - self._registered = [] - self._log = log - - def register(self, listeners): - for listener in listeners: - listener.register() - self._registered.append(listener) - - def __enter__(self): - return self - - def __exit__(self, type, value, tb): - while self._registered: - listener = self._registered.pop() - try: - listener.deregister() - except Exception: - self._log.warn("Failed deregistering listener '%s'", - listener, exc_info=True) - - class ExponentialBackoff(object): """An iterable object that will yield back an exponential delay sequence. |
