Parallelise pulp_container_content

Author: Alex-Welsh

roles/pulp_container_content/tasks/main.yml

@@ -1,6 +1,21 @@
 ---
+- name: Initialize active tasks list
+  set_fact:
+    pulp_container_active_tasks: []
+
 - name: Add or remove content units
   include_tasks: process_content.yml
   loop: "{{ pulp_container_content }}"
   loop_control:
     loop_var: content_item
+
+- name: Wait for tasks to complete
+  pulp.squeezer.task:
+    pulp_url: "{{ pulp_url }}"
+    username: "{{ pulp_username }}"
+    password: "{{ pulp_password }}"
+    validate_certs: "{{ pulp_validate_certs | bool }}"
+    pulp_href: "{{ item }}"
+    state: completed
+  loop: "{{ pulp_container_active_tasks }}"
+  when: pulp_container_content_wait | bool

roles/pulp_container_content/tasks/process_content.yml

@@ -118,15 +118,11 @@
     - content_units | length > 0
   changed_when: true
 
-- name: Wait for task completion
-  pulp.squeezer.task:
-    pulp_url: "{{ pulp_url }}"
-    username: "{{ pulp_username }}"
-    password: "{{ pulp_password }}"
-    validate_certs: "{{ pulp_validate_certs | bool }}"
-    pulp_href: "{{ item.response.pulp_href }}"
-    state: completed
+- name: Register active tasks
+  set_fact:
+    pulp_container_active_tasks: "{{ pulp_container_active_tasks + [item.response.pulp_href] }}"
   loop: "{{ [add_result, remove_result] }}"
   when:
+    - item is defined
     - item.changed | default(false)
-    - pulp_container_content_wait | bool
+    - item.response.pulp_href is defined