i@ dZddlZddlmZddlmZmZddlmZm Z m Z m Z ddl m Z ddlmZmZej"eZGd d Zy) 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. N) monotonic)heappushheappop)AnyCallableListOptional)Task)LockEventcheZdZd dZdZdedeegefde fdZ dedeegefde fd Z d d Z y) SchedulerreturnNcNg|_t|_t|_y)N)_queuer _lockr _event)selfs r/var/www/html/hwPaymentPortal-be-dev/hw-payment-portal-api/venv/lib/python3.12/site-packages/psycopg_pool/sched.py__init__zScheduler.__init__s"$ V g g@delayactionc@t|z}|j||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}dddr|jj |S#1swY'xYw)znEnter a new task in the queue at an absolute time. Schedule a `!None` to stop the execution. rN)r rrrrset)rrrtaskfirsts rrzScheduler.enterabs.sd D&! ZZ + T[[$ 'KKNd*E +  KKOO   + +s (A''A0c@|j} |j5t}|r|dnd}|r-|j|kr t |n|j|z }d}n |j }|j jdddr|jsy |jn|j j#1swYFxYw#t$r@}tjd|j|jj|Yd}~Qd}~wwxYw)zExecute the events scheduled.rNz$scheduled task run %s failed: %s: %s)rrrrrEMPTY_QUEUE_TIMEOUTrclearr Exceptionloggerwarning __class____name__wait)rqnowr!res rrunz Scheduler.run=s KK $k qtdyyC' $ C# 44E !!# ${{KKM   '9 $ $$!NN>  ,, s$A)CCC D6DD)rN) r* __module__ __qualname__rr$floatr rrr rrr/rrrrsd  +5+(8BG3D*E+$+ U HXb#g5F,G D (rr)__doc__loggingrrheapqrrtypingrrrr _taskr _acompatr r getLoggerr*r'rr3rrr;s= #00!   8 $?(?(r