Make publication of repos non-blocking [RHELDST-6394]

Previously ubipop waited for each triplet of repos
(binary, debug, source) that were currently
in processing until publication of those repos
is finished. Only after publication finished,
ubipop was allowed to start processing another triplet.
As repo triplet is independent from other ones, it's
not required to do this in blocking way. So now
publication of repos is triggered at the same time
as before but waiting for all to finish is moved to
end of ubipop processing.

ubipop/__init__.py

@@ -247,6 +247,8 @@ def populate_ubi_repos(self):
         # multiple times, to avoid that, cache the content sets already used and skip the config
         # whose content sets are all in the cache
 
+        awaited_repos_publishes = []
+
         for config in sorted(self.ubiconfig_list, key=str):
             content_sets = [
                 config.content_sets.rpm.output,
@@ -275,7 +277,7 @@ def populate_ubi_repos(self):
                 right_config = self._get_config(
                     repo_set.out_repos.rpm.ubi_config_version, config
                 )
-                UbiPopulateRunner(
+                repos_publishes = UbiPopulateRunner(
                     self.pulp,
                     self.pulp_client,
                     repo_set,
@@ -285,6 +287,13 @@ def populate_ubi_repos(self):
                 ).run_ubi_population()
 
                 out_repos.update(repo_set.get_output_repo_ids())
+                # in case of dry-run there are no publications expected
+                if repos_publishes:
+                    awaited_repos_publishes.extend(repos_publishes)
+
+        # wait until publication of all repos is finished
+        if awaited_repos_publishes:
+            f_sequence(awaited_repos_publishes).result()
 
         if self.output_repos:
             with open(self.output_repos, "w") as f:
@@ -722,8 +731,8 @@ def run_ubi_population(self):
                 (mdd_association,), (mdd_unassociation,)
             )
 
-            # wait repo publication
-            f_sequence(self._publish_out_repos()).result()
+            # return list of futures with repo publishes
+            return self._publish_out_repos()
 
     def _associate_unassociate_units(self, action_list):
         fts = []