fix: proper sync task calling

openedx · Jan 12, 2024 · 4233732 · 4233732
1 parent 6ba56d2
commit 4233732
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/enterprise_catalog/apps/catalog/management/commands/reindex_algolia.py b/enterprise_catalog/apps/catalog/management/commands/reindex_algolia.py
@@ -50,8 +50,9 @@ def handle(self, *args, **options):
                 logger.info(
                     'index_enterprise_catalog_in_algolia_task launching synchronously.'
                 )
-                # For some reason in order to call a celery task in-memory you must pass kwargs as args.
-                index_enterprise_catalog_in_algolia_task(force_task_execution, dry_run)
+                index_enterprise_catalog_in_algolia_task.apply(
+                    kwargs={'force': force_task_execution, 'dry_run': dry_run}
+                )
             else:
                 index_enterprise_catalog_in_algolia_task.apply_async(
                     kwargs={'force': force_task_execution, 'dry_run': dry_run}