From 19b9fa00f2b5e0e17281ded37da28a8a64f0e1e9 Mon Sep 17 00:00:00 2001 From: Dennis Kliban Date: Thu, 27 Jul 2023 17:00:10 -0400 Subject: [PATCH] Moves TaskGroup.finish() to outside the loop in the replication task fixes: #4175 (cherry picked from commit 4ced14e949d2311627b82380e63d0853247df764) --- CHANGES/4175.bugfix | 2 ++ pulpcore/app/tasks/replica.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) create mode 100644 CHANGES/4175.bugfix diff --git a/CHANGES/4175.bugfix b/CHANGES/4175.bugfix new file mode 100644 index 0000000000..13a8ea0342 --- /dev/null +++ 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 index a995e474dd..283c63aab9 100644 --- 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()