chaoswg.scheduler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	TaskScheduler.__init__()	0	6	1
A	TaskScheduler.run()	0	4	2
A	TaskScheduler.schedule_tasks()	0	13	4

import threading
import time
from datetime import datetime

import schedule

from chaoswg import Task


class TaskScheduler(threading.Thread):

The variable __class__ seems to be unused.

    def __init__(self, interval=60):
        # init a daemonized thread
        threading.Thread.__init__(self, daemon=True)
        self.interval = interval
        # run an update every hour
        schedule.every().hour.do(self.schedule_tasks)

    @staticmethod
    def schedule_tasks():
        now = datetime.utcnow()
        schedule_tasks = Task.get_schedule_tasks()

        for task in schedule_tasks:
            if task['last_done'] is not None:
                delta = now - task['last_done']
                if delta.days >= task['schedule_days']:
                    Task.set_todo(task['id'])
            else:
                # Task was not done yet
                Task.set_todo(task['id'])

    def run(self):
        while True:
            schedule.run_pending()
            time.sleep(self.interval)