uʴhSrSSKrSSKJr SSKJr \R RSS5 \"S5r\RSS S 9 \R5 S S 0S S 0S S0S S0S.\Rl S\Rl S S S.S S S.SSS.SSS.S.\Rl\RRSSSSSSS/\R SSSSSS9 SSSS .S!S"S#S .S$S%S&S .S'.\RlS\RlS\Rl\"\S(5(a\R*\Rl\R/SS)9S*5r\R/SS)9S+5rg),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:settingsCELERY) namespacequeuestream_processingjingle_detection notifications monitoring)zapps.streams.tasks.*zapps.jingles.tasks.*zapps.notifications.tasks.*zapps.monitoring.tasks.*default)exchange routing_key)r r r r iiXigzipjsonTi) result_expirestask_time_limittask_soft_time_limitresult_compressiontask_serializerresult_serializeraccept_contenttimezone enable_utcworker_prefetch_multiplierworker_max_tasks_per_childtask_acks_latetask_reject_on_worker_lostz10/m<) rate_limit max_retriesdefault_retry_delayz50/mz100/m )z!apps.streams.tasks.capture_streamz apps.jingles.tasks.detect_jinglez.apps.notifications.tasks.send_telegram_messageCELERY_BEAT_SCHEDULE)bindcf[SUR<35 SURR3$)aC 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)selfs 7C:\Users\brahi\OneDrive\Desktop\Code\src\core\celery.py debug_taskr2s. Idll% &' 1$,,//1B CCcSSKJn [SUSU35 [RR S5(aUR SUSU35 g) 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: ENABLEDu&🚨 Task Failure Alert 🚨 Task ID: z Error: T)apps.notifications.tasksr5r-rTELEGRAM_CONFIGgetdelay)r0task_iderror tracebackr5s r1task_failure_handlerr>sc"? E')E7 +,##I..##y!W  r3)__doc__osceleryr django.confrenviron setdefaultappconfig_from_objectautodiscover_tasksconf task_routestask_default_queue task_queuesupdate TIME_ZONEtask_annotationsworker_send_task_eventstask_send_sent_eventhasattrr* beat_scheduletaskr2r>r3r1rUs    .@ Vn-B %&9:$&89#*O"< '6 ((* ') $& !##28    ##/>!*!)!7.$( $ 8+,,%::CHHtDD$tr3