
    6i                         d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dlm	Z	 d dl
mZ  e j                  e      Z e       Zd Zy)	    N)BackgroundScheduler)CronTrigger)datetime)get_db_session)
CronJobLog)compute_service_level_dailyc                      t         j                  ryd } t         j                  | t        dd      dd       t         j	                          t
        j                  d	       y)
z0Service level computation cron - runs at 2:00 AMNc                     t               } 	 t        ddt        j                               }| j	                  |       | j                          t        j                         }|j                  |_	        | j                          | j                          y # t        $ r"}t        j                  d|        Y d }~7d }~ww xY w# | j                          w xY w)Nservice_levelstarted)	task_typestatus
started_atzService level cron error: )r   r   r   utcnowaddcommitr   delayidtask_id	Exceptionloggererrorclose)dbcron_logtaskes       J/var/www/html/hubwallet-dev/src/smart_inventory/jobs/service_level_cron.pyjobzservice_level_cron.<locals>.job   s    	!) #??,H
 FF8IIK.446D#wwHIIK
 HHJ  	;LL5aS9::	; HHJs*   A6B 	B>B94C 9B>>C C   r   )hourminuter   T)r   replace_existingz,Service level cron started - runs at 3:00 AM)	schedulerrunningadd_jobr   startr   info)r   s    r   service_level_cronr)      sK    ( c;Aa8__cdOO
KK>?    )logging!apscheduler.schedulers.backgroundr   apscheduler.triggers.cronr   r   src.utils.dbr   #src.smart_inventory.jobs.cron_modelr   ,src.smart_inventory.tasks.service_level_taskr   	getLogger__name__r   r$   r)    r*   r   <module>r4      s:     A 1  ' : T			8	$!	@r*   