Dispatch replication task with shared [server] resources.

dkliban · dralley · commit a96a42754b66 · 2026-03-23T22:22:32.000-04:00
fixes: #7520
diff --git a/CHANGES/7520.bugfix b/CHANGES/7520.bugfix
@@ -0,0 +1,2 @@
+Fixed a bug where a worker would start running `finalize_replication` task before the
+`replicate_distributions` task finishes.
diff --git a/pulpcore/app/viewsets/replica.py b/pulpcore/app/viewsets/replica.py
@@ -134,6 +134,7 @@ def replicate(self, request, pk):
         dispatch(
             replicate_distributions,
             exclusive_resources=exclusive_resources,
+            shared_resources=[server],
             kwargs={"server_pk": pk},
             task_group=task_group,
         )

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	+Fixed a bug where a worker would start running `finalize_replication` task before the
	`2`	+`replicate_distributions` task finishes.
Original file line number	Diff line number	Diff line change
`@@ -134,6 +134,7 @@ def replicate(self, request, pk):`
`134`	`134`	`dispatch(`
`135`	`135`	`replicate_distributions,`
`136`	`136`	`exclusive_resources=exclusive_resources,`
	`137`	`+ shared_resources=[server],`
`137`	`138`	`kwargs={"server_pk": pk},`
`138`	`139`	`task_group=task_group,`
`139`	`140`	`)`