fix: removed limitation of Celery task names

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"),

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,

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