WIP

frestq/decorators.py

@@ -57,9 +57,9 @@ def decorator(view_func):
             wrapper_func = view_func
         else:
             def wrapper_func(*args, **kwargs):
-                print(f"task: Starting task\n\n")
+                print(f"task: Starting task")
                 ret = view_func(*args, **kwargs)
-                print(f"task: Finished task\n\n")
+                print(f"task: Finished task")
                 return ret
 
         ActionHandlers.add_action_handler(action, queue, wrapper_func, kwargs)
@@ -99,9 +99,9 @@ def __call__(self, *args):
         if certs_differ(sender_ssl_cert, local_ssl_cert):
             raise SecurityException()
 
-        print(f"local_task: Starting task.id={task.task_model.id}\n\n")
+        print(f"local_task: Starting task.id={task.task_model.id}")
         ret = self.func(*args)
-        print(f"local_task: Finished task.id={task.task_model.id}\n\n")
+        print(f"local_task: Finished task.id={task.task_model.id}")
         return ret
 
 def internal_task(name, **kwargs):

frestq/protocol.py

@@ -77,6 +77,7 @@ def update_task(msg):
         raise  SecurityException()
 
     keys = ['output_data', 'status']
+
     for key in keys:
         if key not in msg.input_data:
             continue
@@ -94,6 +95,10 @@ def update_task(msg):
                 f"({task.id}) **NOT** SETTING TASK FIELD '{key}' to "
                 f"'{str_data}' because it's already 'finished'"
             )
+            # do next (it might be a task with a parent task)
+            receiver_task = BaseTask.instance_by_model(task)
+            receiver_task.execute()
+            return
         else:
             logging.debug(
                 f"({task.id}) SETTING TASK FIELD '{key}' to '{str_data}'"