
    f6i8                     4   d dl mZ d dlmZ  e       Z edej
                  ej                  g d      Zej                  j                  dddd	did	d
id	did	did	did	diddddddddddddddddd       ej                  d      defd       Zy)     )Celery)get_settingsnotification_service)zapp.workers.notificationszapp.workers.deliverieszapp.workers.webhookszapp.workers.dlqzapp.workers.crm_synczapp.workers.scheduled_sender)brokerbackendincludeT   notificationsqueue
deliverieswebhooksdlqcrm_sync)zapp.workers.notifications.*zapp.workers.deliveries.*zapp.workers.webhooks.*zapp.workers.dlq.*zapp.workers.crm_sync.*zapp.workers.scheduled_sender.*zapp.workers.dlq.replay_dlqg     r@)taskschedulez&app.workers.notifications.cleanup_logsg      @z'app.workers.crm_sync.scheduled_sync_allz9app.workers.scheduled_sender.send_scheduled_notificationsg      N@z2app.workers.scheduled_sender.cleanup_old_scheduledg     @)z
replay-dlqzcleanup-logszscheduled-crm-synczsend-scheduled-notificationszcleanup-old-scheduled)task_acks_lateworker_prefetch_multipliertask_default_queuetask_routesbeat_schedulezapp.workers.ping)namereturnc                       y)Npong r       $/var/www/notifications/app/worker.pypingr   :   s    r   N)celeryr   app.core.configr   settingscelery_broker_urlcelery_result_backend
celery_appconfupdater   strr   r   r   r   <module>r(      s     ( >%%**	
    &(/'A%,l$;#*J"7%u-#*J"7+2O*D 1

 =

 >

 P)

 I"
#  "J ()c  *r   