g lSrSSKJr SSKrSSKJr SSKrSSKJr SSK J r SS K J r \ r "S S 5rg) The QueueManager class.) annotationsN) Coroutine) HomeAssistant)HacsExecutionStillInProgress)LOGGERcl\rSrSrSrS Sjr\S Sj5r\S Sj5rSSjr SSjr SSS jjr S r g) QueueManagerrc,Xl/UlSUlg)NFhassqueuerunning)selfrs 5/config/custom_components/hacs/utils/queue_manager.py__init__QueueManager.__init__s &(  c,[UR5$)-Return a count of pending tasks in the queue.)lenrrs r pending_tasksQueueManager.pending_taskss4::rc URS:g$)rr)rrs rhas_pending_tasksQueueManager.has_pending_taskss!!Q&&rc/Ulg)zClear the queue.N)rrs rclearQueueManager.clear#s  rc:URRU5 g)zAdd a task to the queue.N)rappend)rtasks raddQueueManager.add's $rNc# UR(a[RS5 [e[ UR 5S:Xa[RS5 gSUl[RS5 /nU(a(UR SUHnUR U5 M O$UR HnUR U5 M [RS[ U55 [R"5n[R"USS06IShvN nUH0n[U[5(dM[RS U5 M2 [R"5U- nUHnUR RU5 M [RS [ U5U5 UR(a)[RS [ UR 55 S UlgN7f) zExecute the tasks in the queue.z+ Execution is already runningrz! 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_LOGGERdebugrrrr%timeasynciogather isinstance Exceptionerrorremover)rnumber_of_tasks local_queuer&startresultentryends rexecuteQueueManager.execute+sw << MMG H. . tzz?a  MM= >   DE  #3O4""4(5 ""4(#  LcR]N^_ ~~{KdKKE%++ 159iikE!D JJ  d #   [     ! ! MMJCPTPZPZO \ !LsDG7G5G7=B9G7r)rrreturnNone)r<int)r<bool)r<r=)r&rr<r=)N)r4z int | Noner<r=) __name__ __module__ __qualname____firstlineno____doc__rpropertyrrr"r'r:__static_attributes__rrr r sF! '' ''rr )rD __future__rr.collections.abcrr-homeassistant.corer exceptionsrloggerr r+r rGrrrMs."% ,5 AAr