o
    Ղig                     @   s
  d Z ddlmZ ddlmZ ddlmZ e Zedejej	g ddZ
e
jjddgdd	d
d
ddddd
d
ejddejiid dedddddgdddejiddeddddg ddddejiddedddd d!dddejidd"e
j_ed#kre
  d!S d!S )$u!   Celery 应用配置 + Beat 调度    )Celery)crontab)get_settingsdata_center)zapp.tasks.processor_taskszapp.tasks.ocr_taskszapp.tasks.asr_tasks)brokerbackendincludejsonzAsia/ShanghaiTi`T  iPF     d   zapp.tasks.processor_tasks.*queue)task_serializeraccept_contentresult_serializertimezone
enable_utctask_track_startedtask_time_limittask_soft_time_limitworker_prefetch_multiplierworker_max_tasks_per_childtask_acks_latetask_reject_on_worker_losttask_default_queuetask_routesz1app.tasks.processor_tasks.incremental_update_task      )hourminute      )category_idswindow_days)taskschedulekwargsoptions      )r   r   day_of_week)r
   r   r'         r         )r   r   day_of_monthN)zincremental-daily-high-freqzincremental-weekly-low-freqzincremental-monthly-full-check__main__)__doc__celeryr   celery.schedulesr   
app.configr   settingscelery_broker_urlcelery_result_backend
celery_appconfupdatecelery_task_queuebeat_schedule__name__start r>   r>   </lsinfo/ai/hellotax_ai/data_center/backend/app/celery_app.py<module>   sj    
(

%