dinislage/web2py
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #357 from niphlod/enhancement/scheduler_prevent_drift

Browse Source 
added the prevent_drift parameter
This commit is contained in:
mdipierro
2014-01-23 20:33:40 -08:00
parent 4cbdf612af 9434baba11
commit cc297a06d3
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
gluon/scheduler.py
+10 -2
View File
@@ -507,6 +507,8 @@ class Scheduler(MetaScheduler):
requires=IS_INT_IN_RANGE(-1, None)), requires=IS_INT_IN_RANGE(-1, None)),
Field('period', 'integer', default=60, comment='seconds', Field('period', 'integer', default=60, comment='seconds',
requires=IS_INT_IN_RANGE(0, None)), requires=IS_INT_IN_RANGE(0, None)),
Field('prevent_drift', 'boolean', default=False,
comment='Cron-like start_times between runs'),
Field('timeout', 'integer', default=60, comment='seconds', Field('timeout', 'integer', default=60, comment='seconds',
requires=IS_INT_IN_RANGE(0, None)), requires=IS_INT_IN_RANGE(0, None)),
Field('sync_output', 'integer', default=0, Field('sync_output', 'integer', default=0,
@@ -635,9 +637,15 @@ class Scheduler(MetaScheduler):
else: else:
logger.info('nothing to do') logger.info('nothing to do')
return None return None
next_run_time = task.last_run_time + datetime.timedelta(
seconds=task.period)
times_run = task.times_run + 1 times_run = task.times_run + 1
if not task.prevent_drift:
next_run_time = task.last_run_time + datetime.timedelta(
seconds=task.period
)
else:
next_run_time = task.start_time + datetime.timedelta(
seconds=task.period * times_run
)
if times_run < task.repeats or task.repeats == 0: if times_run < task.repeats or task.repeats == 0:
#need to run (repeating task) #need to run (repeating task)
run_again = True run_again = True