Skip to content

Commit 5e66bfe

Browse files
authored
Merge pull request #69 from serv-c/drgroot-patch-1
fix(hooks): delete part queue on completion
2 parents 99c7db9 + 411fa6f commit 5e66bfe

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ def process_post_part_hook(
3636

3737
# check if all parts are complete
3838
if bus.get_queue_length(partHook["part_queue"]) == partHook["total_parts"]:
39+
bus.delete_queue(partHook["part_queue"])
3940
return True
4041
return False
4142

0 commit comments

Comments
 (0)