
    i                     ~    d dl Z d dlmZ d dlmZ d dlmZ d dlmZ  e            Z	 e j
        e          Zd Zd ZdS )    N)timezone)save_daily_data)AsyncIOScheduler)CronTriggerc                    K   t                               d           	 t                              d           n# t          $ r Y nw xY wt                              dt          t          ddt          d                    ddd	           t          j	        st          
                                 t                               d
           dS )u9   Initialize system jobs — called during FastAPI startup.zInitializing system jobs...daily_data_insert_job   r   zAmerica/New_York)hourminuter      T)idfunctriggermax_instancescoalescereplace_existingz.Daily data insert job scheduled for 4:00 AM ETN)loginfo	scheduler
remove_job	Exceptionadd_jobr   r   r   runningstart     7/var/www/html/ls-ibe-bot-apis/app/services/scheduler.pyinitialize_system_jobsr      s      HH*+++45555    "011
 
 

       HH=>>>>>s   9 
AAc                  \   K   t           j        rt                               d           d S d S )NF)wait)r   r   shutdownr   r   r   shutdown_system_jobsr"   *   s8       '&&&&&' 'r   )loggingpytzr   app.utils.daily_data_insertr   apscheduler.schedulers.asyncior   apscheduler.triggers.cronr   r   	getLogger__name__r   r   r"   r   r   r   <module>r*      s           7 7 7 7 7 7 ; ; ; ; ; ; 1 1 1 1 1 1	g!!
? ? ?8' ' ' ' 'r   