fix: use celery properly

openedx · Oct 3, 2023 · abe673a · abe673a
1 parent e5a5bcc
commit abe673a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/enterprise_catalog/apps/catalog/management/commands/compare_catalog_queries_to_filters.py b/enterprise_catalog/apps/catalog/management/commands/compare_catalog_queries_to_filters.py
@@ -20,4 +20,4 @@ def handle(self, *args, **options):
         Compare the Enterprise Catalog Query results to our own Catalog Filter vai task
         """
         logger.info("compare_catalog_queries_to_filters queuing task...")
-        compare_catalog_queries_to_filters_task.s()
+        compare_catalog_queries_to_filters_task.apply_async()
diff --git a/...catalog/apps/catalog/management/commands/tests/test_compare_catalog_queries_to_filters.py b/...catalog/apps/catalog/management/commands/tests/test_compare_catalog_queries_to_filters.py
@@ -20,4 +20,4 @@ def test_update_content_metadata_for_all_queries(
         """
         call_command(self.command_name)
         compare_catalog_queries_to_filters_task()
-        mock_compare_catalog_queries_to_filters_task.s.assert_called_once()
+        mock_compare_catalog_queries_to_filters_task.apply_async.assert_called_once()