We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents a79b8c8 + f2a96dd commit 99c7db9Copy full SHA for 99c7db9
servc/svc/com/worker/hooks/parallelize.py
@@ -83,8 +83,8 @@ def evaluate_part_pre_hook(
83
complete_hook.append(newHook)
84
85
# create task queue
86
+ task_queue = f"part.{route}-{method}-{message['id']}"
87
if len(jobs):
- task_queue = f"part.{route}-{method}-{message['id']}"
88
bus.create_queue(task_queue, False)
89
90
# publish messages to part queue
0 commit comments