U h@sHdZddlZddlmZddlmZejddedZej dd d e d d id d id did didej _ dej _ d d dd d ddddddddej _ej jdddddddgejdddddd dddd d!d"d#d d$d%d&d d'ej _dej _dej _eed(rejej _ejdd)d*d+Zejdd)d,d-ZdS).a Celery configuration for Stream Processor Django project. This module configures Celery for handling background tasks such as: - Stream capture and processing - Jingle detection and ad break analysis - Telegram notification sending - Periodic maintenance tasks - File system monitoring Celery allows the application to process time-consuming tasks asynchronously, improving user experience and system responsiveness. N)Celery)settingsDJANGO_SETTINGS_MODULEz core.settingscorezdjango.conf:settingsZCELERY) namespacequeuestream_processingjingle_detection notifications monitoring)zapps.streams.tasks.*zapps.jingles.tasks.*zapps.notifications.tasks.*zapps.monitoring.tasks.*default)ZexchangeZ routing_key)rr r r iiXigzipjsonTi) Zresult_expiresZtask_time_limitZtask_soft_time_limitZresult_compressionZtask_serializerZresult_serializerZaccept_contenttimezoneZ enable_utcZworker_prefetch_multiplierZworker_max_tasks_per_childZtask_acks_lateZtask_reject_on_worker_lostz10/m<)Z rate_limitZ max_retriesZdefault_retry_delayz50/mz100/m )z!apps.streams.tasks.capture_streamz apps.jingles.tasks.detect_jinglez.apps.notifications.tasks.send_telegram_messageCELERY_BEAT_SCHEDULE)bindcCstd|jd|jjS)ao Debug task for testing Celery configuration. This task can be used to verify that Celery is properly configured and can execute tasks. It's primarily used for debugging and testing. Args: self: The task instance (automatically provided by bind=True) Returns: str: Debug information about the task execution z Request: z$Debug task executed successfully at )printrequestid)selfr//var/www/html/JingleDetector/src/core/celery.py debug_tasksrcCsFddlm}td|d|tjdrB|d|d|dS) a Handle task failures for monitoring and alerting. This task is called when other tasks fail, allowing for centralized error handling, logging, and notification of failures. Args: self: The task instance task_id (str): ID of the failed task error (str): Error message from the failed task traceback (str): Stack trace of the failure Returns: bool: True if failure handling was successful r)send_telegram_messagezTask z failed: ZENABLEDu&🚨 Task Failure Alert 🚨 Task ID: z Error: T)Zapps.notifications.tasksr rrZTELEGRAM_CONFIGgetdelay)rZtask_iderror tracebackr rrrtask_failure_handlers  r%)__doc__osceleryr django.confrenviron setdefaultappZconfig_from_objectZautodiscover_tasksconfZ task_routesZtask_default_queueZ task_queuesupdate TIME_ZONEZtask_annotationsZworker_send_task_eventsZtask_send_sent_eventhasattrrZ beat_scheduletaskrr%rrrrs|