openstack/deb-python-taskflow
Code Issues Proposed changes

Merge "Just directly access the callback attributes"

Browse Source
This commit is contained in:
Jenkins
2015-02-06 06:20:23 +00:00
committed by Gerrit Code Review
parent 64593258b3 bb4304810b
commit 6c84acd80a
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
taskflow/types/periodic.py
View File

@@ -111,11 +111,11 @@ class PeriodicWorker(object):
self._immediates = []
now = _now()
for i, (cb, cb_name) in enumerate(self._callables):
spacing = getattr(cb, '_periodic_spacing')
spacing = cb._periodic_spacing
next_run = now + spacing
heapq.heappush(self._schedule, (next_run, i))
for (cb, cb_name) in reversed(self._callables):
if getattr(cb, '_periodic_run_immediately', False):
if cb._periodic_run_immediately:
self._immediates.append((cb, cb_name))
def __len__(self):
@@ -154,7 +154,7 @@ class PeriodicWorker(object):
when_next = next_run - now
if when_next <= 0:
cb, cb_name = self._callables[i]
spacing = getattr(cb, '_periodic_spacing')
spacing = cb._periodic_spacing
LOG.debug("Calling periodic callable '%s' (it runs every"
" %s seconds)", cb_name, spacing)
self._safe_call(cb, cb_name)
@@ -175,5 +175,5 @@ class PeriodicWorker(object):
self._tombstone.clear()
self._immediates = []
for (cb, cb_name) in reversed(self._callables):
if getattr(cb, '_periodic_run_immediately', False):
if cb._periodic_run_immediately:
self._immediates.append((cb, cb_name))