Cj58%SrSSKJr SSKrSSKrSSKrSSKJr SSKJ r SSK J r SSK J r JrJrJrJrJrJrJr SSKrSSKJr SS KJr \ (a SS KJr SS KJr \"S 5rS \ S '"SS\!5r""SS\!5r#"SS\#5r$"SS\#5r%"SS\#5r&S$Sjr'"SS\RP5r)\"S5r*\\/\SS\*44\/\*4\\*4r+S\ S'"SS 5r,\RZR]S!S"9"S#S\\*55r/g)%zx This module contains the `Worker` class and related objects. See the guide for how to use [workers](/guide/workers). ) annotationsN) ContextVar)Event) monotonic) TYPE_CHECKING AwaitableCallable CoroutineGenericTypeVarUnioncast) TypeAlias)Message)App)DOMNode active_workerzContextVar[Worker]c\rSrSrSrSrg)NoActiveWorker)zThere is no active worker.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r`/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/textual/worker.pyrr)s$rrc\rSrSrSrSrg) WorkerError-zA worker related error.rNrrrr r"r"-s!rr"c0^\rSrSrSrSU4SjjrSrU=r$) WorkerFailed1z4The worker raised an exception and did not complete.c8>Xl[TU] SU<35 g)NzWorker raised exception: )errorsuper__init__)selfr( __class__s r r*WorkerFailed.__init__4s  4UI>?r)r()r( BaseExceptionreturnNone)rrrrrr*r __classcell__r,s@r r%r%1s>@@rr%c\rSrSrSrSrg) DeadlockError9z)The operation would result in a deadlock.rNrrrr r4r49s3rr4c\rSrSrSrSrg)WorkerCancelled=z.The worker was cancelled and did not complete.rNrrrr r7r7=s8rr7Workerc`[R5$![a [S5Sef=f)z}Get the currently active worker. Raises: NoActiveWorker: If there is no active worker. Returns: A Worker instance. z1There is no active worker in this task or thread.N)rget LookupErrorrrrr get_current_workerr=As8  ""  ?  s-c4\rSrSrSrSrSrSrSrSr Sr g ) WorkerStateRz,A description of the worker's current state.rN) rrrrrPENDINGRUNNING CANCELLEDERRORSUCCESSrrrr r?r?Rs-6G1GI3 E:GA class to manage concurrent work (either a task or a thread).c:^\rSrSrSrSU4SjjrSSjrSrU=r$)Worker.StateChangedzzThe worker state changed.c:>XlX l[TU] 5 g)zaInitialize the StateChanged message. Args: worker: The worker object. state: New state. N)workerstater)r*)r+rarbr,s r r*Worker.StateChanged.__init__~s!KJ G  rc#D# URv URv g7frQ)rarbrVs r __rich_repr__!Worker.StateChanged.__rich_repr__s++ ** s )rbra)rar9rbr?r/r0r/zrich.repr.Result) rrrrrr*rerr1r2s@r StateChangedr^zs'   rrhFra)bubble namespacedefaultT)namegroup description exit_on_errorthreadcXlX lX0lX@l[ U5S::aUOUSSS-UlX`l[5UlXpl [RUl URUl SUlSUlSUlSUl[%5UlSUlSUlURR-UR/XR55 g)aInitialize a Worker. Args: node: The widget, screen, or App that initiated the work. work: A callable, coroutine, or other awaitable object to run in the worker. name: Name of the worker (short string to help identify when debugging). group: The worker group. description: Description of the worker (longer string with more details). exit_on_error: Exit the app if the worker raises an error. Set to `False` to suppress exceptions. thread: Mark the worker as a thread worker. iNz...rF)_node_workrmrnlenrorprcancelled_event_thread_workerr?rF_staterb_error_completed_steps _total_steps _cancelledr _created_time_result_task post_messagerh)r+nodeworkrmrnrorprqs r r*Worker.__init__s,    {+t3KUd9Ke9S +&+gA$!)) [[ ,0 %&(, %&[*. *.   1 1$ DErc## [URR5v SURS4v SURS4v SURS4v S[ UR S5S4v g7f) NrmrkrnrlroprogressrA)rNrbrmrnroroundrrVs r reWorker.__rich_repr__se ((dii##tzz9,,T--r11% q1366sA1A3cUR$)z(The node where this worker was run from.)rsrVs r r Worker.nodeszzrcUR$)z The current state of the worker.)rxrVs r rb Worker.state{{rcXR:gnXlU(a+URRURX55 gg)z"Set the state, and send a message.N)rxrsrrh)r+rbchangeds r rbrs:;;&  JJ # #D$5$5d$B C rcUR$)zMHas the work been cancelled? Note that cancelled work may still be running. )r|rVs r is_cancelledWorker.is_cancelleds rc<UR[R:H$)zIs the task running?)rbr?rGrVs r is_runningWorker.is_runningszz[0000rczUR[R[R[R4;$)z5Has the task finished (cancelled, error, or success)?)rbr?rHrIrJrVs r is_finishedWorker.is_finisheds5zz  ! !         rcUR$)zThe number of completed steps.rzrVs r completed_stepsWorker.completed_stepss$$$rcUR$)z4The number of total steps, or None if indeterminate.)r{rVs r total_stepsWorker.total_stepss   rcUR(dg[S[SURUR- S-55$)zProgress as a percentage. If the total steps is None, then this will return 0. The percentage will be clamped between 0 and 100. rrdgY@)r{maxminrzrVs r rWorker.progresss:   1c# 5 58I8I IURSTTrcUR$)z:The result of the worker, or `None` if there is no result.)r~rVs r result Worker.results||rcUR$)zDThe exception raised by the worker, or `None` if there was no error.)ryrVs r r( Worker.errorrrNcnUbU=RU- slUS:waUcSO [SU5Ulgg)zUpdate the number of completed steps. Args: completed_steps: The number of completed seps, or `None` to not change. total_steps: The total number of steps, `None` for indeterminate, or -1 to leave unchanged. Nr)rzrr{)r+rrs r update Worker.updates>  &  ! !_ 4 ! " (3(;Q ATD  rc.U=RU- slg)zUAdvance the number of completed steps. Args: steps: Number of steps to advance. Nr)r+stepss r advanceWorker.advances &rcL^^# SU4SjjmSU4SjjnS U4Sjjn[R"TR5(dJ[TRS5(a2[R"TRR5(aUnOP[R "TR5(aTnO([ TR5(aUnO [S5e[R"5nUceURSUTR5IShvN $N7f) z?Run a threaded worker. Returns: Return value of the work. cN>^SUU4Sjjn[R"U"55$)z.Set the active worker and await the awaitable.cN># [RT5 TIShvN $N7frQrset)r+rsr do_work.run_awaitable..do_work&s!!$'!z!zs %#%r/rK)asynciorun)rrr+s` r run_awaitable+Worker._run_threaded..run_awaitable#s  " ";;wy) )rc>T"U"55$)z*Set the active worker and await coroutine.r)rrs r run_coroutine+Worker._run_threaded..run_coroutine,s!( (rc<>[RT5 U"5$)z-Set the active worker, and call the callable.r)rr+s r run_callable*Worker._run_threaded..run_callable2s   d #6Mrfuncz*Unsupported attempt to run a thread workerN)rzAwaitable[ResultType]r/rK)rz/Callable[[], Coroutine[None, None, ResultType]]r/rK)rzCallable[[], ResultType]r/rK) inspectiscoroutinefunctionrthasattrr isawaitablecallabler"rget_running_looprun_in_executor)r+rrrunnerlooprs` @r _run_threadedWorker._run_threadeds * )A )  )    ' ' 3 3tzz6**++DJJOO<<"F   , ,"F djj ! !!FJK K'')))$ CCCCsDD$D"D$c# [R"UR5(dJ[URS5(aG[R"URR5(aUR5IShvN $[R "UR5(aURIShvN $[ UR5(a [S5e[S5eNmN67f)z=Run an async worker. Returns: Return value of the work. rNz6Request to run a non-async function as an async workerz*Unsupported attempt to run an async worker)rrrtrrrrr"rVs r _run_asyncWorker._run_asyncHs  ' ' 3 3tzz6**++DJJOO<<% %   , ,# # djj ! !VW WFGG &#s$BC7C38C7>C5?5C75C7c# UR(aUR5OUR5IShvN $N7f)zRun the work. Implement this method in a subclass, or pass a callable to the constructor. Returns: Return value of the work. N)rwrrrVs r r Worker.runZs3%)$7$7D   T__=N   s 5><>c # UR5 [RU5 [RUlUR RU5 UR5IShvN Ul [RUlUR RU5 SSS5 gNB![Ra@n[RUlX lUR RU5 SnANZSnAf[an[R UlX lUR RUS[#U55 SSKJn UR RU"55 UR((a&[+UR5nUR-U5 SnAGN SnAff=f!,(df  g=f7f)z.Run the worker. Args: app: App instance. Nfailedr) Traceback)_contextrrr?rGrblograrr~rJrCancelledErrorrHry ExceptionrIreprrich.tracebackrrpr%_handle_exception)r+appr(r worker_faileds r _run Worker._runfs+ \\^   d #$,,DJ GGNN4  %%)XXZ/ )00 t$/^ 0)) %(22 # t$$ 9(.. # tXtE{;4y{+%%$0$=M))-8 9^slG AF:B2-B0. B270F:' G 0B22F76D<F: F7BF2,F:2F77F:: GG c^^TRbg[RTl[R "TR U55TlSUU4SjjnTRRU5 g)zpStart the worker. Args: app: An app instance. done_callback: A callback to call when the task is done. Nc>Tb T"T5 gg)zURun the callback. Called by `Task.add_done_callback`. Args: The worker's task. Nr)r done_callbackr+s r task_done_callback)Worker._start..task_done_callbacks(d#)r)rz asyncio.Taskr/r0)rr?rGrbr create_taskradd_done_callback)r+rrrs` ` r _start Worker._startsX :: !  (( ((38  $ $ $$%78rcSUlURbURR5 URR 5 g)zCancel the task.TN)r|rcancelrvrrVs r r Worker.cancels5 :: ! JJ      "rc# [R5ULa [S5eUR[ R :Xa [S5eURbURIShvN UR[ R:Xa$URce[UR5eUR[ R:Xa [S5e[!SUR"5$![a Nf=fN![Ra%n[ RUlXl SnANSnAff=f7f)zWait for the work to complete. Raises: WorkerFailed: If the Worker raised an exception. WorkerCancelled: If the Worker was cancelled before it completed. Returns: The return value of the work. z7Can't call worker.wait from within the worker function!z2Worker must be started before calling this method.Nz+Worker was cancelled, and did not complete.rK)rr;r4r<rbr?rFr"rrrrHryrIr%r7rr~)r+r(s r wait Worker.waits   "d*#M+ ::,, ,RS S :: ! $jj   ::** *;;* **t{{+ + ZZ;00 0!"OP PL$,,//#   !)) $(22 #  $sdE"C37ED-D.D2BE3 D=E?DEDD>D94E9D>>E)r|rzr}ryrsr~rxrrwr{rtrvrorprnrmrb)rrrrLrmrYrnrYrorYrpboolrqrr/r0rg)r/r)r/r?)rbr?r/r0)r/r)r/int)r/ int | None)r/float)r/zResultType | None)r/zBaseException | None)Nr)rrrrr/r0)rA)rrr/r0r)rrr/r0rQ)rrrzCallable[[Worker], None] | Noner/r0)r/r0)"rrrrrrichrautorrhr*repropertyrrbsetterrrrrrrrr(rrrrrrrrrrrrr r9r9vsH YY^^wu."*F*F*F  *F  *F*F*F*F *FX7 \\DD11  %%!!UU MO U) U?I U  U'*DXH$  %@JN99'F9 96# 0r)r/r9)0r __future__rrenumr contextvarsr threadingrtimertypingrrr r r r r r rich.reprrtyping_extensionsrtextual.messager textual.appr textual.domrr__annotations__rrr"r%r4r7r=Enumr?rKrLrNrrr9rrr rs># "   '##%/$? !?*%Y%")"@;@4K49k9" =$)) =\ "  R4z12 23 R^ j) 0P0WZ P0P0r