Skip to content

Commit f2a96dd

Browse files
authored
fix(hooks): fixed bound error in parallelize
1 parent a79b8c8 commit f2a96dd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

servc/svc/com/worker/hooks/parallelize.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ def evaluate_part_pre_hook(
8383
complete_hook.append(newHook)
8484

8585
# create task queue
86+
task_queue = f"part.{route}-{method}-{message['id']}"
8687
if len(jobs):
87-
task_queue = f"part.{route}-{method}-{message['id']}"
8888
bus.create_queue(task_queue, False)
8989

9090
# publish messages to part queue

0 commit comments

Comments
 (0)