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

log formatted

Browse source
This commit is contained in:
Volkan Şahin 2016-10-18 18:13:30 +03:00
parent 0dc7d8f639
commit 5c5a332e09
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
opt/ahenk/base/scheduler/custom/schedule_job.py
View file

@ -23,26 +23,26 @@ class ScheduleTaskJob(object):
self.months = self.conv_to_set(cron_sj[3]) self.months = self.conv_to_set(cron_sj[3])
self.dow = self.conv_to_set(cron_sj[4]) self.dow = self.conv_to_set(cron_sj[4])
self.action = self.process_task self.action = self.process_task
self.logger.debug('[ScheduleTaskJob] Instance created.') self.logger.debug('Instance created.')
except Exception as e: except Exception as e:
self.logger.error( self.logger.error(
'[ScheduleTaskJob] A problem occurred while creating instance of ScheduleTaskJob. Error Message : {0}'.format( 'A problem occurred while creating instance of ScheduleTaskJob. Error Message : {0}'.format(
str(e))) str(e)))
def process_task(self): def process_task(self):
try: try:
self.logger.debug('[ScheduleTaskJob] Running scheduled task now...') self.logger.debug('Running scheduled task now...')
self.plugin_manager.process_task(self.task) self.plugin_manager.process_task(self.task)
self.logger.debug('[ScheduleTaskJob] Scheduled Task was executed.') self.logger.debug('Scheduled Task was executed.')
# There is no any single shot task # There is no any single shot task
# if self.is_single_shot(): # if self.is_single_shot():
# Scope.getInstance().get_scheduler().remove_job(self.task.get_id()) # Scope.getInstance().get_scheduler().remove_job(self.task.get_id())
except Exception as e: except Exception as e:
self.logger.error( self.logger.error(
'[ScheduleTaskJob] A problem occurred while running scheduled task. Error Message: {0}'.format(str(e))) 'A problem occurred while running scheduled task. Error Message: {0}'.format(str(e)))
def parse_cron_str(self, cron_str): def parse_cron_str(self, cron_str):
self.logger.debug('[ScheduleTaskJob] Parsing cron string...') self.logger.debug('Parsing cron string...')
try: try:
cron_exp_arr = cron_str.split(" ") cron_exp_arr = cron_str.split(" ")
cron_sj = [] cron_sj = []
@ -65,19 +65,19 @@ class ScheduleTaskJob(object):
elif count == 3: elif count == 3:
cron_sj.append(range(0, 7, range_val)) cron_sj.append(range(0, 7, range_val))
else: else:
self.logger.warning('[ScheduleTaskJob] Unsupported expression.') self.logger.warning('Unsupported expression.')
elif ',' in exp: elif ',' in exp:
cron_sj.append("(" + str(exp) + ")") cron_sj.append("(" + str(exp) + ")")
else: else:
self.logger.warning('[ScheduleTaskJob] Unsupported expression.') self.logger.warning('Unsupported expression.')
count = count + 1 count += 1
return cron_sj return cron_sj
except Exception as e: except Exception as e:
self.logger.error( self.logger.error(
'[ScheduleTaskJob] A problem occurred while parsing cron expression. Error Message: {0}'.format(str(e))) 'A problem occurred while parsing cron expression. Error Message: {0}'.format(str(e)))
def conv_to_set(self, obj): def conv_to_set(self, obj):
self.logger.debug('[ScheduleTaskJob] Converting {0} to set'.format(str(obj))) self.logger.debug('Converting {0} to set'.format(str(obj)))
if str(obj).isdigit(): if str(obj).isdigit():
return set([int(obj)]) return set([int(obj)])