U lh @sdZddlmZmZddlZddlmZddlmZej ddedZ e j d d d e e jjd d d gd d ddd dd dd dddddide jd dddZe jddZdS)a Celery configuration for Adtlas DAI Management System. This module configures Celery for handling background tasks such as: - VAST call processing - Ad encoding operations - Analytics data processing - Report generation - File transfers - Notification sending Celery is used for: 1. Asynchronous task execution 2. Periodic task scheduling 3. Task result storage 4. Task monitoring and management For more information on Celery configuration, see: https://docs.celeryproject.org/en/stable/django/first-steps-with-django.html )absolute_importunicode_literalsN)Celery)settingsDJANGO_SETTINGS_MODULEz core.settingsZadtlaszdjango.conf:settingsZCELERY) namespaceTjsonzredis://redis:6379/0UTCFiiZ master_nameZmymaster)Ztask_track_startedZtask_serializerZaccept_contentZresult_serializerZ"broker_connection_retry_on_startupZresult_backendtimezoneZ enable_utcZtask_always_eagerZtask_eager_propagatesZtask_ignore_resultZtask_store_eager_resultZworker_prefetch_multiplierZworker_max_tasks_per_childZresult_expiresZ result_backend_transport_options)bindcCstd|jd|jjS)a Debug task for testing Celery configuration. This task can be used to verify that Celery is working correctly. It prints the request information and returns a success message. Returns: str: Debug information about the task request z Request: z.Debug task executed successfully. Request ID: )printrequestid)selfr'/var/www/html/Adtlas/src/core/celery.py debug_taskLs rcCsddtdS)z Health check task for monitoring Celery workers. This task can be used by monitoring systems to verify that Celery workers are responsive and functioning correctly. Returns: dict: Health status information ZhealthyzAdtlas Celery Worker)statusZservice timestamp)appnow isoformatrrrr health_check[s  r)__doc__ __future__rrosceleryr django.confrenviron setdefaultrZconfig_from_objectZautodiscover_tasksconfupdatetaskrrrrrrs@  !