|
@ -39,17 +39,23 @@ class Scheduler(Plugin): |
|
|
|
|
|
|
|
|
# Crons |
|
|
# Crons |
|
|
for identifier in self.crons: |
|
|
for identifier in self.crons: |
|
|
self.remove(identifier) |
|
|
try: |
|
|
cron = self.crons[identifier] |
|
|
self.remove(identifier) |
|
|
job = self.sched.add_cron_job(cron['handle'], day = cron['day'], hour = cron['hour'], minute = cron['minute']) |
|
|
cron = self.crons[identifier] |
|
|
cron['job'] = job |
|
|
job = self.sched.add_cron_job(cron['handle'], day = cron['day'], hour = cron['hour'], minute = cron['minute']) |
|
|
|
|
|
cron['job'] = job |
|
|
|
|
|
except ValueError, e: |
|
|
|
|
|
log.error("Failed adding cronjob: %s" % e) |
|
|
|
|
|
|
|
|
# Intervals |
|
|
# Intervals |
|
|
for identifier in self.intervals: |
|
|
for identifier in self.intervals: |
|
|
self.remove(identifier) |
|
|
try: |
|
|
interval = self.intervals[identifier] |
|
|
self.remove(identifier) |
|
|
job = self.sched.add_interval_job(interval['handle'], hours = interval['hours'], minutes = interval['minutes'], seconds = interval['seconds'], repeat = interval['repeat']) |
|
|
interval = self.intervals[identifier] |
|
|
interval['job'] = job |
|
|
job = self.sched.add_interval_job(interval['handle'], hours = interval['hours'], minutes = interval['minutes'], seconds = interval['seconds'], repeat = interval['repeat']) |
|
|
|
|
|
interval['job'] = job |
|
|
|
|
|
except ValueError, e: |
|
|
|
|
|
log.error("Failed adding interval cronjob: %s" % e) |
|
|
|
|
|
|
|
|
# Start it |
|
|
# Start it |
|
|
self.sched.start() |
|
|
self.sched.start() |
|
|