Minor improvement in poolJobs debug string.
bzr revid: p_christ@hol.gr-20090823174649-inkws3li8qiben21
This commit is contained in:
parent
8cbe393b52
commit
1e0de079ac
|
@ -220,7 +220,7 @@ class Agent(object):
|
||||||
def setAlarm(self, fn, dt, db_name, *args, **kwargs):
|
def setAlarm(self, fn, dt, db_name, *args, **kwargs):
|
||||||
wait = dt - time.time()
|
wait = dt - time.time()
|
||||||
if wait > 0:
|
if wait > 0:
|
||||||
self._logger.notifyChannel('timers', LOG_DEBUG, "Job scheduled in %s seconds for %s.%s" % (wait, fn.im_class.__name__, fn.func_name))
|
self._logger.notifyChannel('timers', LOG_DEBUG, "Job scheduled in %.3g seconds for %s.%s" % (wait, fn.im_class.__name__, fn.func_name))
|
||||||
timer = threading.Timer(wait, fn, args, kwargs)
|
timer = threading.Timer(wait, fn, args, kwargs)
|
||||||
timer.start()
|
timer.start()
|
||||||
self._timers.setdefault(db_name, []).append(timer)
|
self._timers.setdefault(db_name, []).append(timer)
|
||||||
|
|
Loading…
Reference in New Issue