You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
51 lines
1.5 KiB
51 lines
1.5 KiB
import sys
|
|
import os
|
|
sys.path.append(os.path.normpath(os.path.join(os.path.dirname(__file__), '../lib')))
|
|
import init
|
|
import misc
|
|
from models import Transient
|
|
from misc import printdbg
|
|
import time
|
|
import random
|
|
|
|
|
|
class Scheduler(object):
|
|
transient_key_scheduled = 'NEXT_SENTINEL_CHECK_AT'
|
|
random_interval_max = 1200
|
|
|
|
@classmethod
|
|
def is_run_time(self):
|
|
next_run_time = Transient.get(self.transient_key_scheduled) or 0
|
|
now = misc.now()
|
|
|
|
printdbg("current_time = %d" % now)
|
|
printdbg("next_run_time = %d" % next_run_time)
|
|
|
|
return now >= next_run_time
|
|
|
|
@classmethod
|
|
def clear_schedule(self):
|
|
Transient.delete(self.transient_key_scheduled)
|
|
|
|
@classmethod
|
|
def schedule_next_run(self, random_interval=None):
|
|
if not random_interval:
|
|
random_interval = self.random_interval_max
|
|
|
|
next_run_at = misc.now() + random.randint(1, random_interval)
|
|
printdbg("scheduling next sentinel run for %d" % next_run_at)
|
|
Transient.set(self.transient_key_scheduled, next_run_at,
|
|
next_run_at)
|
|
|
|
@classmethod
|
|
def delay(self, delay_in_seconds=None):
|
|
if not delay_in_seconds:
|
|
delay_in_seconds = random.randint(0, 60)
|
|
|
|
# do not delay longer than 60 seconds
|
|
# in case an int > 60 given as argument
|
|
delay_in_seconds = delay_in_seconds % 60
|
|
|
|
printdbg("Delay of [%d] seconds for cron minute offset" % delay_in_seconds)
|
|
time.sleep(delay_in_seconds)
|