From 42337321f692743c7106619856efc68989a910fb Mon Sep 17 00:00:00 2001 From: John Nagro Date: Fri, 12 Jan 2024 14:45:56 +0000 Subject: [PATCH] fix: proper sync task calling --- .../apps/catalog/management/commands/reindex_algolia.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/enterprise_catalog/apps/catalog/management/commands/reindex_algolia.py b/enterprise_catalog/apps/catalog/management/commands/reindex_algolia.py index d75d24a09..e2c6145e4 100644 --- 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}