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

schedule task bugfix

Browse source
This commit is contained in:
Edip YILDIZ 2017-08-11 10:19:15 +03:00
parent dbdad57305
commit 43961a436f
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
opt/ahenk/base/task/task_manager.py
View file

@ -5,6 +5,7 @@
from base.scope import Scope from base.scope import Scope
from base.model.message_factory import MessageFactory from base.model.message_factory import MessageFactory
from base.model.enum.message_type import MessageType from base.model.enum.message_type import MessageType
import json
class TaskManager(object): class TaskManager(object):
@ -50,8 +51,11 @@ class TaskManager(object):
str(task.get_plugin().get_user_oriented()), str(task.get_plugin().get_version()), str(task.get_plugin().get_user_oriented()), str(task.get_plugin().get_version()),
str(task.get_plugin().get_task_plugin()), str(task.get_plugin().get_x_based())] str(task.get_plugin().get_task_plugin()), str(task.get_plugin().get_x_based())]
plugin_id = self.db_service.update('plugin', plu_cols, plugin_args) plugin_id = self.db_service.update('plugin', plu_cols, plugin_args)
params = json.dumps(task.get_parameter_map())
values = [str(task.get_id()), str(task.get_create_date()), str(task.get_modify_date()), values = [str(task.get_id()), str(task.get_create_date()), str(task.get_modify_date()),
str(task.get_command_cls_id()), task.get_parameter_map(), str(task.get_deleted()), str(task.get_command_cls_id()), str(params), str(task.get_deleted()),
str(plugin_id), str(task.get_cron_str()), str(task.get_file_server())] str(plugin_id), str(task.get_cron_str()), str(task.get_file_server())]
self.db_service.update('task', task_cols, values) self.db_service.update('task', task_cols, values)
except Exception as e: except Exception as e: