diff --git a/servc/svc/com/worker/hooks/parallelize.py b/servc/svc/com/worker/hooks/parallelize.py index 20f3195..3ac9a92 100644 --- a/servc/svc/com/worker/hooks/parallelize.py +++ b/servc/svc/com/worker/hooks/parallelize.py @@ -83,8 +83,8 @@ def evaluate_part_pre_hook( complete_hook.append(newHook) # create task queue + task_queue = f"part.{route}-{method}-{message['id']}" if len(jobs): - task_queue = f"part.{route}-{method}-{message['id']}" bus.create_queue(task_queue, False) # publish messages to part queue