ujSrSSKJr SSKrSSKJr SSKJr SSKJ r J r J r J r SSK rSSKJrJrJr \ (a SSKJr SS KJr \R.R1S S 9"S S 55rg)z Contains `WorkerManager`, a class to manage [workers](/guide/workers) for an app. You access this object via [App.workers][textual.app.App.workers] or [Widget.workers][textual.dom.DOMNode.workers]. ) annotationsN)Counter) attrgetter) TYPE_CHECKINGAnyIterableIterator)Worker WorkerStateWorkType)App)DOMNodeT)angularc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS S jjr S S S S S SSS.S!Sjjr S"SjrS#SjrS#SjrS$SjrS%SjrS&S'SjjrSrg)( WorkerManagerzAn object to manage a number of workers. You will not have to construct this class manually, as widgets, screens, and apps have a worker manager accessibly via a `workers` attribute. c0Xl[5Ulg)z>Initialize a worker manager. Args: app: An App instance. N)_appset_workers)selfapps ڤC:\Users\johnn\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.13_qbz5n2kfra8p0\LocalCache\local-packages\Python313\site-packages\textual/worker_manager.py__init__WorkerManager.__init__s  %%(U (c## [5nURSUR55 [UR 55Hup#UR U4v M g7f)Nc38# UHoRv M g7fN)state).0workers r .WorkerManager.__rich_repr__..,s@-||-s)rupdatersorteditemsname)rcounterr counts r __rich_repr__WorkerManager.__rich_repr__*sH(/ @$--@@"7==?3LE**e# #4sA A"cN[[UR[S5S95$)N _created_time)keyiterr&rrrs r__iter__WorkerManager.__iter__0sF4==j.IJKKrcP[[UR[S5SS95$)Nr.T)r/reverser0r2s r __reversed__WorkerManager.__reversed__3s$ 4==j&A4 P  rc,[UR5$r)boolrr2s r__bool__WorkerManager.__bool__8sDMM""rc,[UR5$r)lenrr2s r__len__WorkerManager.__len__;s4==!!rcXR;$r)rrr"s r __contains__WorkerManager.__contains__>s&&rTcU(a7UR(a&URURUR5 URR U5 U(a'UR UR UR5 gg)zAdd a new worker. Args: worker: A Worker instance. start: Start the worker if True, otherwise the worker must be started manually. exclusive: Cancel all workers in the same group as `worker`. N)group cancel_groupnoderadd_startr_remove_worker)rr"start exclusives r add_workerWorkerManager.add_workerAsW    fkk6<< 8 &!  MM$))T%8%8 9 rdefaultF)r(rF description exit_on_errorrLrMthreadc [UUU=(d [USS5=(d SUU=(d [U5UU S9n URXUS9 U $)aCreate a worker from a function, coroutine, or awaitable. Args: work: A callable, a coroutine, or other awaitable. name: A name to identify the worker. group: The worker group. description: A description of the worker. exit_on_error: Exit the app if the worker raises an error. Set to `False` to suppress exceptions. start: Automatically start the worker. exclusive: Cancel all workers in the same group. thread: Mark the worker as a thread worker. Returns: A Worker instance. __name__rP)r(rFrRrSrT)rLrM)r getattrreprrN) rworkrHr(rFrRrSrLrMrTr"s r _new_workerWorkerManager._new_workerQsV8%  <z26<"#1tDz'  yA rc:URRU5 g)zHRemove a worker from the manager. Args: worker: A Worker instance. N)rdiscardrBs rrKWorkerManager._remove_workerys f%rcvURH)nURURUR5 M+ g)zStart all the workers.N)rrJrrKrBs r start_allWorkerManager.start_alls(mmF MM$))T%8%8 9$rcJURHnUR5 M g)zCancel all workers.N)rcancelrBs r cancel_allWorkerManager.cancel_allsmmF MMO$rcURVs/sH)nURU:XdMURU:XdM'UPM+ nnUHnUR5 M U$s snf)zCancel a single group. Args: node: Worker DOM node. group: A group name. Returns: A list of workers that were cancelled. )rrFrHrc)rrHrFr"workerss rrGWorkerManager.cancel_groupsd-- ' % *0++*= '  F MMO sAAAcURVs/sHo"RU:XdMUPM nnUHnUR5 M U$s snf)zCancel all workers associated with a given node Args: node: A DOM node (widget, screen, or App). Returns: List of cancelled workers. )rrHrc)rrHr"rgs r cancel_nodeWorkerManager.cancel_nodesC)- M f9L6 MF MMONs A A Nc# [R"U=(d UVs/sHo"R5PM sn6IShvN gs snfN ![Ra gf=f7f)zyWait for workers to complete. Args: workers: An iterable of workers or None to wait for all workers in the manager. N)asynciogatherwaitCancelledError)rrgr"s rwait_for_completeWorkerManager.wait_for_completesR  ..4"QV;;="QR R R"Q R%%   sDA(AAAA AA(AA%"A($A%%A()rr)rr returnNone)rszrich.repr.Result)rszIterator[Worker[Any]])rsr:)rsint)r"objectrsr:)TT)r"r rLr:rMr:rsrt)rYr rHrr(z str | NonerFstrrRrwrSr:rLr:rMr:rTr:rsr )r"r rsrt)rsrt)rHrrFrwrs list[Worker])rHrrsrxr)rgzIterable[Worker] | Nonersrt)rV __module__ __qualname____firstlineno____doc__rr+r3r7r;r?rCrNrZrKr`rdrGrjrq__static_attributes__rrrrs )$ L #"'EI::%):=A: :*"&&&  &  &&&&&& &P&:  &   rr)r| __future__rrm collectionsroperatorrtypingrrrr rich.reprrichtextual.workerr r r textual.appr textual.domrrXautorr~rrrs[ #9988#]]]r