Mercurial > repos > borgend / file revision

#
# Borgend scheduler
#

from Queue import Queue
from runborg import BorgInstance
import sched
import ui

def scheduler(sched):
    timeout=???
    q=sched.eventqueue
    while True:
        timeout, timerevent=next_timed_event(sched);
        t=Timer(timeout, lambda: q.put(timerevent));
        event=sq.get(True):
        # Decide what to do

class Scheduler:

    def __init__(self, backups):
        self.backups=backups
        self.eventqueue=Queue()
        self.t=Thread(target=scheduler, args=self)