gi< dZddlmZddlZddlmZddlmZmZddl m Z m Z ddl m Z dd lmZmZejeZGd d ZdS) a A minimal scheduler to schedule tasks to run in the future (sync version). Inspired to the standard library `sched.scheduler`, but designed for multi-thread usage from the ground up, not as an afterthought. Tasks can be scheduled in front of the one currently running and `Scheduler.run()` can be left running without any tasks scheduled. Tasks are called "Task", not "Event", here, because we actually make use of `[threading/asyncio].Event` and the two would be confusing. ) annotationsN) monotonic)heappopheappush)AnyCallable)Task)EventLockc2eZdZddZdZdd Zdd Zdd ZdS) SchedulerreturnNonec`g|_t|_t|_dS)N)_queuer _lockr _event)selfs b/var/www/html/Pagina-Ingenieria-Requisitos/venv/lib/python3.11/site-packages/psycopg_pool/sched.py__init__zScheduler.__init__!s#"$ VV gg g@delayfloatactionCallable[[], Any] | Noner cPt|z}|||S)zpEnter a new task in the queue delayed in the future. Schedule a `!None` to stop the execution. )renterabs)rrrtimes renterzScheduler.enter(s& {{U"}}T6***rrct||}|j5t|j||jd|u}dddn #1swxYwY|r|j|S)znEnter a new task in the queue at an absolute time. Schedule a `!None` to stop the execution. rN)r rrrrset)rrrtaskfirsts rrzScheduler.enterabs0s D&!! Z + + T[$ ' ' 'KNd*E + + + + + + + + + + + + + + +   KOO    s%A  A A c|j} |j5t}|r|dndx}r(|j|krt |n|j|z }d}n|j}|jdddn #1swxYwY|rb|jsdS |n]#t$r6}t d|j|j j |Yd}~n"d}~wwxYw|j|)zExecute the events scheduled.TrNz$scheduled task run %s failed: %s: %s)rrrrrEMPTY_QUEUE_TIMEOUTrclearr Exceptionloggerwarning __class____name__wait)rqnowr#res rrunz Scheduler.run?s K ( $ $kk$%/AaDD4045yC'' $ C# 4E !!### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ ({EKKMMMM NN>  ,    '''7 (s*A%BBBB-- C-7,C((C-N)rr)rrrrrr )rrrrrr )r, __module__ __qualname__rr&r rr1rrrrsl  ++++    ((((((rr)__doc__ __future__rloggingrrheapqrrtypingrr_taskr _acompatr r getLoggerr,r)rr4rrr=s  #"""""######## !!!!!!!!  8 $ $>(>(>(>(>(>(>(>(>(>(r