isdZddlZddlmZddlmZddlmZeje Z deiZ deiZ ddd d Z ee e e d Zd ZdZdZy)zv Configuracion centralizada del scheduler con APScheduler. Gestiona el ciclo de vida de todas las tareas programadas. N)AsyncIOScheduler)MemoryJobStore)AsyncIOExecutordefaultT)coalesce max_instancesmisfire_grace_timezAmerica/Guayaquil) jobstores executors job_defaultstimezonecpddlm}tj|dddddtj d y ) zh Registra todos los jobs en el scheduler. Importa y agrega cada job definido en tasks/jobs/ r sync_data_jobintervalrrzSincronizacion de datosT)triggerminutesidnamereplace_existingu%📋 Jobs registrados en el schedulerN)tasks.jobs.sync_datar scheduleradd_jobloggerinfors //opt/lhia/marcimex/agent/app/tasks/scheduler.py register_jobsr$s= 3  &  KK78c dtjrtjdyt tj tj dtj}|D]>}tj d|jd|jd|j@y)z3Inicia el scheduler con todos los jobs registrados.u%⚠️ El scheduler ya esta corriendoNu$⏰ Scheduler iniciado correctamentez - z (ID: z) -> Siguiente: ) rrunningrwarningrstartrget_jobsrr next_run_time)jobsjobs rstart_schedulerr)8s>?O OO KK67    DY eCHH:VCFF83CCDUDUCVWXYr ctjr,tjdtj dytj dy)z%Detiene el scheduler de forma segura.T)waitu%🛑 Scheduler detenido correctamenteu'⚠️ El scheduler no estaba corriendoN)rr"shutdownrrr#r rstop_schedulerr.Hs6% ;<@Ar )__doc__loggingapscheduler.schedulers.asynciorapscheduler.jobstores.memoryrapscheduler.executors.asyncior getLogger__name__rr r rrrr)r.r-r rr6s;79   8 $~          9( Y Br