ijSSKJr SSKrSSKJrJrJr SSKJr SSK J r J r J r SSK Jr \(aSSKJr "S S \R"\5rg) ) annotationsN)AnyAsyncGenerator TYPE_CHECKING)WorkflowRuntimeError)Event StopEventInternalDispatchEvent) RunResultT)Contextc^\rSrSr%SrS\S'S\S'S\S'S \S 'S S S .SU4S jjjr\SSj5rSSjr SSjr SSjr SSjr SSjr SSSjjrS SjrSrU=r$)!WorkflowHandlera Handle a running workflow: await results, stream events, access context, or cancel. Instances are returned by [Workflow.run][workflows.workflow.Workflow.run]. They can be awaited for the final result and support streaming intermediate events via [stream_events][workflows.handler.WorkflowHandler.stream_events]. See Also: - [Context][workflows.context.context.Context] - [StopEvent][workflows.events.StopEvent] r _ctxasyncio.Task[None] | None _run_taskbool_all_events_consumedStopEvent | None _stop_eventN)run_idrun_taskcX>[TU]"U0UD6 X lXlX0lSUlg)NF)super__init__rrrr)selfctxrrargskwargs __class__s K/home/james-whalen/.local/lib/python3.13/site-packages/workflows/handler.pyrWorkflowHandler.__init__%s. $)&)  !$)!cUR$)zGThe workflow [Context][workflows.context.context.Context] for this run.)rrs r"rWorkflowHandler.ctx3syyr$cUR$)zThe stop event for this run. Always defined once the future is done. In a future major release, this will be removed, and the result will be the stop event itself.)rr&s r"get_stop_eventWorkflowHandler.get_stop_event8sr$c~# UR5IShvN URcS5eUR$N$7f)zGet the stop event for this run. Always defined once the future is done. In a future major release, this will be removed, and the result will be the stop event itself.Nz3Stop event must be defined once the future is done.)resultrr&s r"stop_event_result!WorkflowHandler.stop_event_result<sCkkm+ A + s =;%=cxXlUR[U5[LaUR5 gU5 gN)r set_resulttyper r,)r stop_events r"_set_stop_eventWorkflowHandler._set_stop_eventDs3% !%j!1Y!>J   DN r$c4[UR55$r0)strr,r&s r"__str__WorkflowHandler.__str__Ms4;;=!!r$c"UR5$)z,Return True when the workflow has completed.)doner&s r"is_doneWorkflowHandler.is_donePsyy{r$c# UR(a Sn[U5eURR5ShvN n[ U[ 5(a U(dM'U7v [ U[ 5(dMCSUl gNG g7f)a{ Stream events from the workflow execution as they occur. This method provides real-time access to events generated during workflow execution, allowing for monitoring and processing of intermediate results. Events are yielded in the order they are generated by the workflow. The stream includes all events written to the context's streaming queue, and terminates when a [StopEvent][workflows.events.StopEvent] is encountered, indicating the workflow has completed. Args: expose_internal (bool): Whether to expose internal events. Returns: AsyncGenerator[Event, None]: An async generator that yields Event objects as they are produced by the workflow. Raises: ValueError: If the context is not set on the handler. WorkflowRuntimeError: If all events have already been consumed by a previous call to `stream_events()` on the same handler instance. Examples: ```python handler = workflow.run() # Stream and process events in real-time async for event in handler.stream_events(): if isinstance(event, StopEvent): print(f"Workflow completed with result: {event.result}") else: print(f"Received event: {event}") # Get final result result = await handler ``` Note: Events can only be streamed once per handler instance. Subsequent calls to `stream_events()` will raise a WorkflowRuntimeError. z3All the streamed events have already been consumed.NT)rrr stream_events isinstancer r )rexpose_internalmsgevs r"r?WorkflowHandler.stream_eventsTsp^  $ $GC&s+ +..0 ""344_H"i((,0) 0s-9B B BB 7B > B B  B c# UR(a>URR5 URbURIShvN gggN![a gf=f7f)a)Cancel the running workflow. Signals the underlying context to raise [WorkflowCancelledByUser][workflows.errors.WorkflowCancelledByUser], which will be caught by the workflow and gracefully end the run. Examples: ```python handler = workflow.run() await handler.cancel_run() ``` N)r_workflow_cancel_runr Exceptionr&s r" cancel_runWorkflowHandler.cancel_runsZ 88 HH ) ) +~~)..((* ) s:9A%A A AA%A A"A%!A""A%)rrrrr) rrrr rz str | Nonerrr rreturnNone)rJr )rJr)rJr )r3r rJrK)rJr7)rJr)F)rArrJzAsyncGenerator[Event, None])rJrK)__name__ __module__ __qualname____firstlineno____doc____annotations__rpropertyrr)r-r4r8r<r?rH__static_attributes__ __classcell__)r!s@r"rrs  M((!! ".2 * * * * , *  *  * *   " ',:#: $:xr$r) __future__rasynciotypingrrrerrorsreventsr r r typesr contextr Futurerr$r"r^s@#55);; PgnnZ0Pr$