{iW dZddlZddlZddlmZmZddlmZddlm Z ddl m Z e e Z e jdd d ed ed eeeffd Ze jdd eeeffdZded eeeffdZd ed ed efdZgdZy)z+ Celery Tasks - Background Task Processing N)AnyDict) current_task)get_task_logger) celery_appTsend_welcome_email)bindname user_email user_namereturnc tjd|d|tjd|jj ||dtjd}tjd||S#t $r:}tjdt||j|dd d }~wwxYw) z Send welcome email task - Simple example for demonstration Args: user_email: User's email address user_name: User's display name Returns: Dict containing task result information zSending welcome email to z for user sent)task_idemailr status timestampz#Welcome email sent successfully to zWelcome email sending failed: <)exc countdown max_retriesN) loggerinfotimesleeprequestid Exceptionerrorstrretry)selfr r resultrs N/var/www/html/hwPaymentPortal-be-dev/hw-payment-portal-api/src/worker/tasks.pyrrs? / |:i[QR 1 ||    9*FG ? 5c#hZ@AjjSBAj>>?sA7A:: B=5B88B= health_check)r ctjddtjtrtjj dSddS)zv Health check task for monitoring worker status Returns: Dict containing health check result zPerforming health checkhealthyunknown)rr worker_id)rrrrrhostnamer&r'r'7sK KK)*YY[6B\))22 IR r.rc.tsddiS tj|}||j|j|j|j dS#t $r:}tjdt||dt|dcYd}~Sd}~wwxYw)z Get status of a task by ID Args: task_id: Celery task ID Returns: Dict containing task status information r!Celery not available)rrr% traceback date_donezError getting task status: UNKNOWN)rrr!N) r AsyncResultrr%r1r2r rr!r")rr%rs r&get_task_statusr5Is /00 ''0mmmm))))      23s8*=>X   sAA B/B BBchts tdtj||}|jS)zX Trigger welcome email task from FastAPI Returns: str: Task ID r0)r RuntimeErrorrdelayr)r r tasks r&trigger_welcome_emailr:js. 122  # #J :D 77Nr.)rr'r5r:)__doc__loggingrtypingrrceleryrcelery.utils.logrsrc.worker.celery_appr__name__rr9r"rr'r5r:__all__r-r.r&rCs ,,  "d!56$?$?$?c3h$?7$?Nn% d38n & " S T#s(^ B c c c  r.