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

fixes: #4175
pulp · Jul 28, 2023 · 4ced14e · 4ced14e
1 parent 33ed9a7
commit 4ced14e
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()
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		Fixed bug where the Task Group for replication would be marked as fully dispatched after just one
		replicator.