Moves TaskGroup.finish() to outside the loop in the replication task

fixes: pulp#4175
dkliban · Jul 27, 2023 · 7b7ba97 · 7b7ba97
1 parent 33ed9a7
commit 7b7ba97
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/CHANGES/4175.bugfix b/CHANGES/4175.bugfix
@@ -0,0 +1,2 @@
+Fixed bug where the Task Group for replication would be marked as fully dispatched after just one
+replicator.
diff --git a/pulpcore/app/tasks/replica.py b/pulpcore/app/tasks/replica.py
@@ -98,4 +98,4 @@ def replicate_distributions(server_pk):
             distro_names.append(distro["name"])
 
         replicator.remove_missing(distro_names)
-        task_group.finish()
+    task_group.finish()