Liderahenk/Ahenk
1
0
Fork 0
mirror of https://github.com/Pardus-LiderAhenk/ahenk synced 2024-11-25 21:42:21 +03:00
Code Issues Projects Releases Packages Wiki Activity

scheduled task processing fixed

Browse source
This commit is contained in:
Volkan Şahin 2016-08-10 12:36:17 +03:00
parent 683c5f97b8
commit 26e17d3873
1 changed files with 13 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
opt/ahenk/base/scheduler/custom/custom_scheduler.py
View file

@ -11,7 +11,6 @@ import time
class CustomScheduler(BaseScheduler): class CustomScheduler(BaseScheduler):
def __init__(self): def __init__(self):
self.events = [] self.events = []
self.keep_run = True self.keep_run = True
@ -35,8 +34,10 @@ class CustomScheduler(BaseScheduler):
self.logger.debug('[CustomScheduler] Adding scheduled task to events...') self.logger.debug('[CustomScheduler] Adding scheduled task to events...')
self.events.append(ScheduleTaskJob(task)) self.events.append(ScheduleTaskJob(task))
except Exception as e: except Exception as e:
self.logger.error('[CustomScheduler] A problem occurred while saving and adding job. Error Message: {}'.format(str(e))) self.logger.error(
'[CustomScheduler] A problem occurred while saving and adding job. Error Message: {0}'.format(str(e)))
#unused
def remove_job(self, task_id): def remove_job(self, task_id):
for event in self.events: for event in self.events:
if event.task.get_id() == task_id: if event.task.get_id() == task_id:
@ -45,6 +46,7 @@ class CustomScheduler(BaseScheduler):
self.events.remove(event) self.events.remove(event)
self.logger.debug('[CustomScheduler] Task was removed from events') self.logger.debug('[CustomScheduler] Task was removed from events')
# unused
def remove_job_via_task_id(self, task_id): def remove_job_via_task_id(self, task_id):
for event in self.events: for event in self.events:
if event.task.get_id() == task_id: if event.task.get_id() == task_id:
@ -59,14 +61,14 @@ class CustomScheduler(BaseScheduler):
def run(self): def run(self):
t = datetime(*datetime.now().timetuple()[:5]) t = datetime(*datetime.now().timetuple()[:5])
while 1 and self.keep_run: while 1 and self.keep_run:
if self.events is not None and len(self.events) > 0:
for e in self.events: for e in self.events:
e.check(t) e.check(t)
t += timedelta(minutes=1) t += timedelta(minutes=1)
while datetime.now() < t: if datetime.now() < t:
time.sleep((t - datetime.now()).seconds) sl = (t - datetime.now()).seconds
time.sleep(sl)