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
index fd9b15987..ab8e43073 100644
--- 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/enterprise_catalog/apps/catalog/management/commands/tests/test_compare_catalog_queries_to_filters.py b/enterprise_catalog/apps/catalog/management/commands/tests/test_compare_catalog_queries_to_filters.py
index 26dc03c46..f59334250 100644
--- a/enterprise_catalog/apps/catalog/management/commands/tests/test_compare_catalog_queries_to_filters.py
+++ b/enterprise_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()