
    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_slow_movers_90dc                      t         j                  ryd } t         j                  | t        dd      dd       t         j	                          t
        j                  d	       y)
z-Slow mover computation cron - runs at 3: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slow_moversstarted)	task_typestatus
started_atzSlow movers cron error: )r   r   r   utcnowaddcommitr   delayidtask_id	Exceptionloggererrorclose)dbcron_logtaskes       H/var/www/html/hubwallet-dev/src/smart_inventory/jobs/slow_movers_cron.pyjobzslow_movers_cron.<locals>.job   s    	!' #??,H
 FF8IIK*002D#wwHIIK
 HHJ  	9LL3A3788	9 HHJs*   A6B 	B>B94C 9B>>C C   r   )hourminuter   T)r   replace_existingz*Slow movers cron started - runs at 4:00 AM)	schedulerrunningadd_jobr   startr   info)r   s    r   slow_movers_cronr)      sK    ( c;Aa8]]abOO
KK<=    )logging!apscheduler.schedulers.backgroundr   apscheduler.triggers.cronr   r   src.utils.dbr   #src.smart_inventory.jobs.cron_modelr   *src.smart_inventory.tasks.slow_movers_taskr   	getLogger__name__r   r$   r)    r*   r   <module>r4      s9     A 1  ' : N			8	$!	>r*   