Adjust dispatch calls to core>=3.15 interface

fixes # 9483

CHANGES/9483.bugfix

@@ -0,0 +1 @@
+Changed the use of ``dispatch`` to match the signature from pulpcore>=3.15.

pulp_ansible/app/galaxy/mixins.py

@@ -18,4 +18,4 @@ def _dispatch_import_collection_task(self, temp_file_pk, repository=None, **kwar
             locks.append(repository)
             kwargs["repository_pk"] = repository.pk
 
-        return dispatch(import_collection, locks, kwargs=kwargs)
+        return dispatch(import_collection, exclusive_resources=locks, kwargs=kwargs)

pulp_ansible/app/galaxy/v3/views.py

@@ -327,7 +327,7 @@ def update(self, request, *args, **kwargs):
 
         task = dispatch(
             add_and_remove,
-            [repo_version.repository],
+            exclusive_resources=[repo_version.repository],
             kwargs={
                 "repository_pk": repo_version.repository.pk,
                 "base_version_pk": repo_version.pk,

pulp_ansible/app/tasks/test_tasks.py

@@ -139,13 +139,13 @@ def promote_content(repos_per_task, num_repos_to_update):
         locks.append(repo)
         if len(repos_to_dispatch) == repos_per_task:
             task_args = (random_collection_version.pk, repos_to_dispatch)
-            dispatch(add_content_to_repositories, locks, args=task_args)
+            dispatch(add_content_to_repositories, exclusive_resources=locks, args=task_args)
             repos_to_dispatch = []
             locks = []
 
     if repos_to_dispatch:
         task_args = (random_collection_version.pk, repos_to_dispatch)
-        dispatch(add_content_to_repositories, locks, args=task_args)
+        dispatch(add_content_to_repositories, exclusive_resources=locks, args=task_args)
 
 
 def add_content_to_repositories(collection_version_pk, repositories_pks):

pulp_ansible/app/viewsets.py

@@ -267,7 +267,7 @@ def sync(self, request, pk):
 
         result = dispatch(
             sync_func,
-            [repository, remote],
+            exclusive_resources=[repository, remote],
             kwargs=sync_kwargs,
         )
         return OperationPostponedResponse(result, request)
@@ -304,7 +304,7 @@ def update(self, request, pk, **kwargs):
         lock.extend(repos)
         async_result = dispatch(
             update_collection_remote,
-            lock,
+            exclusive_resources=lock,
             args=(pk,),
             kwargs={"data": request.data, "partial": partial},
         )
@@ -401,7 +401,7 @@ def create(self, request):
 
         config, repos = self._process_config(config)
 
-        async_result = dispatch(copy_content, repos, args=[config], kwargs={})
+        async_result = dispatch(copy_content, exclusive_resources=repos, args=[config], kwargs={})
         return OperationPostponedResponse(async_result, request)
 
     def _process_config(self, config):

pulp_ansible/tests/performance/create_repos_with_collections.py

@@ -67,11 +67,11 @@
     while repos_to_still_make > 0:
         if repos_to_still_make >= args.batch_size[0]:
             task_args = (args.batch_size[0], num_repo_versions_per_repo, collection_percentage)
-            async_result = dispatch(create_repos_with_collections, [], args=task_args)
+            async_result = dispatch(create_repos_with_collections, args=task_args)
             print("Dispatched task with {} repositories".format(args.batch_size[0]))
             repos_to_still_make = repos_to_still_make - args.batch_size[0]
         else:
             task_args = (repos_to_still_make, num_repo_versions_per_repo, collection_percentage)
-            async_result = dispatch(create_repos_with_collections, [], args=task_args)
+            async_result = dispatch(create_repos_with_collections, args=task_args)
             print("Dispatched task with {} repositories".format(repos_to_still_make))
             repos_to_still_make = 0

pulp_ansible/tests/performance/fast_load_collections.py

@@ -33,5 +33,5 @@
         for file in files:
             if file.endswith(".tar.gz"):
                 async_result = dispatch(
-                    import_collection_from_path, [], args=(os.path.join(root, file),)
+                    import_collection_from_path, args=(os.path.join(root, file),)
                 )

pulp_ansible/tests/performance/generate_collections.py

@@ -57,4 +57,4 @@
             "collection_n": args.collections_per_namespace[0],
             "versions_per_collection": args.versions_per_collection[0],
         }
-        async_result = dispatch(create_namespace, [], args=(args.base_path[0],), kwargs=kwargs)
+        async_result = dispatch(create_namespace, args=(args.base_path[0],), kwargs=kwargs)

pulp_ansible/tests/performance/promote.py

@@ -37,4 +37,4 @@
 
 if __name__ == "__main__":
     task_args = (args.repos_per_task[0], args.num_repos_to_update[0])
-    dispatch(promote_content, [], args=task_args)
+    dispatch(promote_content, args=task_args)