helpers.taskschedule

Complexity

Total Complexity

12

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	TaskSchedule.__init__()	0	7	1
A	TaskSchedule.kick_it_off()	0	4	2
B	TaskSchedule.is_time_to_run()	0	18	8
A	TaskSchedule.is_disabled()	0	2	1

import datetime

class TaskSchedule(object):

    def __init__(self, run_on_init=False):
        self.lastrun = None
        self.start = None
        self.pending_run = run_on_init
    #default to 0 seconds means disabled
    #interval is in seconds
        self.interval = 0

    def is_disabled(self):
        return self.interval <= 0

    def is_time_to_run(self):
        if self.is_disabled():
            return False
        now = datetime.datetime.now()
        if self.pending_run:
            self.pending_run = False
            return self.kick_it_off(True)
        if self.lastrun is None and self.start is None:
            #never run before, run now
            return self.kick_it_off(True)
        elif self.start is not None and self.lastrun is None:
            #never run before and after start time
            return self.kick_it_off(now >= self.start)
        else:
            sincelast = now - self.lastrun
            if sincelast.total_seconds() >= self.interval:
                return self.kick_it_off(True)
        return False

    def kick_it_off(self, dorun=False):
        if dorun:
            self.lastrun = datetime.datetime.now()
        return dorun