From 43961a436f893953e356672beb779b522729efd4 Mon Sep 17 00:00:00 2001 From: Edip YILDIZ Date: Fri, 11 Aug 2017 10:19:15 +0300 Subject: [PATCH] schedule task bugfix --- opt/ahenk/base/task/task_manager.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/opt/ahenk/base/task/task_manager.py b/opt/ahenk/base/task/task_manager.py index 8bb1516..2cd1e5b 100644 --- a/opt/ahenk/base/task/task_manager.py +++ b/opt/ahenk/base/task/task_manager.py @@ -5,6 +5,7 @@ from base.scope import Scope from base.model.message_factory import MessageFactory from base.model.enum.message_type import MessageType +import json 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_task_plugin()), str(task.get_plugin().get_x_based())] 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()), - 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())] self.db_service.update('task', task_cols, values) except Exception as e: