9ci dZddlZddlZddlmZmZmZejeZ d de de dee efdee dee f d Z y) a Celery Task Dispatch Helper =========================== Platform-aware Celery task dispatching utility. Uses apply_async on Windows (solo pool) and send_task on Linux (prefork pool). Usage: from src.smart_inventory.utils.celery_dispatch import dispatch_task # Instead of: compute_daily_sales.delay(target_date) result = dispatch_task( "src.smart_inventory.tasks.daily_sales_task.compute_daily_sales", kwargs={"target_date": target_date} ) N)DictAnyOptional task_nameargskwargstask_id countdowncddlm}|d}|i} tjdk(ra|jj |}|r|j ||||Stjd|d|j|||||S|j|||||S#t$r!}tjd |d |d}~wwxYw) aN Dispatch a Celery task with platform-specific handling. Windows (solo pool): Uses direct task import and apply_async Linux (prefork pool): Uses send_task with task name string Args: task_name: Full Celery task name (e.g., "src.smart_inventory.tasks.daily_sales_task.compute_daily_sales") args: Positional arguments for the task kwargs: Keyword arguments for the task task_id: Optional task ID to use countdown: Optional delay in seconds before task execution Returns: AsyncResult or task ID string r) celery_appNwin32)rrr r zTask z! not in registry, using send_taskzFailed to dispatch task z: ) src.utils.celery_workerr sysplatformtasksget apply_asyncloggerdebug send_task Exceptionerror)rrrr r r taskes H/var/www/html/hubwallet-dev/src/smart_inventory/utils/celery_dispatch.py dispatch_taskrs.3 | ~  <<7 "##'' 2D''!#' ( uYK/PQR!++!#' ,''# (   / {"QC@A s$AB.BB C#B??C)NNNN)__doc__rloggingtypingrrr getLogger__name__rstrtupleintrr rr's{" &&   8 $ !!# >> > cN>c] > } >r&