+ "i nRt^RIHt^RIt^RIHt^RIt^RIHt^RI H t ^RI H t ] t !RR4tR#) The QueueManager class.) annotationsN) Coroutine) HomeAssistant)HacsExecutionStillInProgress)LOGGERcz]tRt^tRtRRlt]RRl4t]RRl4tRR lt R R lt RR Rllt Rt R #) QueueManagerrc V^8dQhRRRR/#)hassrreturnNone)formats"5/config/custom_components/hacs/utils/queue_manager.py __annotate__QueueManager.__annotate__s]tc .Wn.VnRVnR#)FNr queuerunning)selfr s&&r__init__QueueManager.__init__s &(  rcV^8dQhRR/#)r r intr)rs"rrrssrc ,\VP4#z-Return a count of pending tasks in the queue.)lenrrs&r pending_tasksQueueManager.pending_taskss4::rcV^8dQhRR/#)r r boolr)rs"rrrs''4'rc VP^8g#r)r"r!s&rhas_pending_tasksQueueManager.has_pending_taskss!!Q&&rcV^8dQhRR/#)r r rr)rs"rrr#strc .VnR#)zClear the queue.N)rr!s&rclearQueueManager.clear#s  rc V^8dQhRRRR/#)r taskrr rr)rs"rrr's   d rc <VPPV4R#)zAdd a task to the queue.N)rappend)rr.s&&raddQueueManager.add's $rNc V^8dQhRRRR/#)r number_of_tasksz int | Noner rr)rs"rrr+s''Z'4'rc "VP'd\PR4\h\ VP 4^8Xd\PR4R#RVn\PR4.pV'd)VP RVFpVP V4K M$VP FpVP V4K \PR\ V44\P!4p\P!VRR/GRjxL pVF1p\V\4'gK\PRV4K3 \P!4V, pVFpVP PV4K \PR \ V4V4VP'd*\PR \ VP 44R VnR#L5i) zExecute the tasks in the queue.z+ Execution is already runningz! The queue is emptyNTz, Checking out tasks to executez4 Starting queue execution for %s tasksreturn_exceptionsz %szM Queue execution finished for %s tasks finished in %.2f secondsz. %s tasks remaining in the queueF)r_LOGGERdebugrr rr0timeasynciogather isinstance Exceptionerrorremover')rr4 local_queuer.startresultentryends&& rexecuteQueueManager.execute+s| <<< MMG H. . tzz?a  MM= >   DE  #3O4""4(5 ""4(#  LcR]N^_ ~~{KdKKE%++ 159iikE!D JJ  d #   [     ! ! ! MMJCPTPZPZO \ !Ls BHBH H!HB?Hr)N) __name__ __module__ __qualname____firstlineno____doc__rpropertyr"r'r+r1rE__static_attributes__rrrr r sF! '' ''rr )rK __future__rr:collections.abcrr9homeassistant.corer exceptionsrloggerrr7r rrrrSs."% ,5 AAr