diff --git a/enteletaor_lib/modules/proc/__init__.py b/enteletaor_lib/modules/proc/__init__.py index e1653c9..d9e2bf2 100644 --- a/enteletaor_lib/modules/proc/__init__.py +++ b/enteletaor_lib/modules/proc/__init__.py @@ -19,8 +19,6 @@ log = logging.getLogger() # ---------------------------------------------------------------------- class ModuleModel(CommonData): target = StringField(required=True) - export_results = StringField(default="") - import_results = StringField(default=None) db = StringField(default=None, label="only for Redis: database to use") broker_type = SelectField(default="redis", choices=[ ("redis", "Redis server"), diff --git a/enteletaor_lib/modules/proc/proc_inject_process.py b/enteletaor_lib/modules/proc/proc_inject_process.py index 9b8ced9..feb2460 100644 --- a/enteletaor_lib/modules/proc/proc_inject_process.py +++ b/enteletaor_lib/modules/proc/proc_inject_process.py @@ -47,7 +47,7 @@ def action_proc_inject_process(config): "id": uuid.uuid1(), "kwargs": {}, "retries": 0, - "task": "tasks.%s" % p["function"], + "task": p["function"], "taskset": None, "timelimit": [ None, diff --git a/enteletaor_lib/modules/proc/utils.py b/enteletaor_lib/modules/proc/utils.py index 3787ccd..13c1674 100644 --- a/enteletaor_lib/modules/proc/utils.py +++ b/enteletaor_lib/modules/proc/utils.py @@ -138,7 +138,8 @@ def list_remote_process(config, queue): # Read info if msg_id not in already_processed: - remote_process = deserialized['task'].split(".")[-1] + # remote_process = deserialized['task'].split(".")[-1] + remote_process = deserialized['task'] remote_args = deserialized['args'] # Store as processed