i#5SSKJr SSKrSSKrSSKJrJrJrJr SSK J r SSK J r J r SSKJr SSKJrJrJrJrJrJrJr SSKJrJr S S jr"S S 5rSSS jjrg)) annotationsN)AnyAsyncGenerator AsyncIteratoroverload)asynccontextmanager) StartEventEvent)Context) HandlerDataHandlersListResponseHealthResponseSendEventResponseStatusWorkflowsListResponseCancelHandlerResponse) EventEnvelopeEventEnvelopeWithMetadatac UR5 g![RanSURRs=::aS:aO eURR SSnUR RnUR RnURRn[R"USURRSUSUSU3 UR URS9UeeSnAff=f) zk Raise an HTTPStatusError with the first 200 characters of the response body for 400 and 500 level errors. iiXN z for z . Response: )requestresponse) raise_for_statushttpxHTTPStatusErrorr status_codetextrmethodurl reason_phrase)re body_previewrr rs Q/home/james-whalen/.local/lib/python3.13/site-packages/workflows/client/client.py_raise_for_status_with_bodyr%!s !!#   !**(( .3 . ::??4C0LYY%%F))--C**00K''-q!9!9 :%xq\ZfYgh     sC9C C44C9cV\rSrSr\SSj5r\SSj5rSSS.SSjjr\SSj5rSSjrSS jr SSS jjr SSS jjr SSS jjr SSS jjr SSjrS S!SjjrSSjrS"S#SjjrSrg)$WorkflowClient6cgN)self httpx_clients r$__init__WorkflowClient.__init__7sr?s r$list_workflowsWorkflowClient.list_workflowsasa##%%#ZZ 55H ' 1(77 H &%%5&%%%rBc`# Ub [USS9n[U[5(aUR 5nU=(d SU=(d 0S.nU(aX&S'UR 5IShvN nURS US 3US 9IShvN n[U5 [R"UR55sSSS5IShvN $![an[SU35eSnAff=f![an[SU35eSnAff=fNNNI!,IShvN (df  g=f7f) a, Run the workflow and wait until completion. Args: start_event (Union[StartEvent, dict[str, Any], None]): start event class or dictionary representation (optional, defaults to None and get passed as an empty dictionary if not provided). context: Context or serialized representation of it (optional, defaults to None if not provided) handler_id (Optional[str]): Workflow handler identifier to continue from a previous completed run. Returns: HandlerData: Data representing the handler running the workflow (including result and metadata) NT)bare4Impossible to serialize the start event because of: 0Impossible to serialize the context because of: r6 start_eventcontext handler_id /workflows/z/runr>) _serialize_event Exceptionr4 isinstancer to_dictr9postr%r r=r> r, workflow_namerMrKrLr" request_bodyr8rs r$ run_workflowWorkflowClient.run_workflowos-$  " .{F gw ' ' Y!//+',"}"  )3 &##%%#[[m_D1 )H ( 1--hmmo>&%%  J1#N  Y #STUSV!WXX Y&&%%%sD. CD.C.6D.-D.D.1D D 2D< D.D D. C+C&&C++D.. D 8DD  D.DD.D+D  D+'D.c# Ub [U5n[U[5(aUR 5nU=(d [[ 55U=(d 0S.nU(aX&S'UR5IShvN nURSUS3US9IShvN n[U5 [R"UR55sSSS5IShvN $![an[SU35eSnAff=f![an[SU35eSnAff=fNNNI!,IShvN (df  g=f7f) a Run the workflow in the background. Args: start_event (Union[StartEvent, dict[str, Any], None]): start event class or dictionary representation (optional, defaults to None and get passed as an empty dictionary if not provided). context: Context or serialized representation of it (optional, defaults to None if not provided) handler_id (Optional[str]): Workflow handler identifier to continue from a previous completed run. Returns: HandlerData: data representing the handler running the workflow. NrHrIrJrMrNz /run-nowaitrO) rPrQr4rRr rSr r9rTr%r r=r>rUs r$run_workflow_nowait"WorkflowClient.run_workflow_nowaits3$  " .{; gw ' ' Y!//+'H*::<*H}"(  )3 &##%%#[[m_K8|)H ( 1--hmmo>&%%  J1#N  Y #STUSV!WXX Y&&%%%sE C EDAE?D ED&D"2D& ED$E C=*C88C==E D DDE"D&$E&D=,D/ - D=9Ec # U(aSOSnSU3nUR5IShvN nURSUSUUS.SS0SS 9IShvN nURS :Xa [S 5eURS :Xa"SSS5IShvN SSS5IShvN g[ U5 UR 5ShvN nUR 5(dM [R"U5n U 7v M>NNNrNdNA![Ran [S U SU35 Sn A MsSn A ff=f SSS5IShvN Oe!,IShvN (df  ON=f![Ra [SU35e[Ran [!SU 35eSn A ff=fSSS5IShvN g!,IShvN (df  g=f7f)a Stream events as they are produced by the workflow. Args: handler_id (str): ID of the handler running the workflow include_internal_events (bool): Include internal workflow events. Defaults to False. lock_timeout (float): Timeout (in seconds) for acquiring the lock to iterate over the events. Returns: AsyncGenerator[EventEnvelopeWithMetadata, None]: Generator for the events that are streamed as instances of `EventEnvelopeWithMetadata`. truefalse/events/NGET)sseinclude_internalacquire_timeout Connectionz keep-alive)paramsheaderstimeoutizHandler not foundzFailed to parse JSON: z, data: z(Timeout waiting for events from handler z#Failed to connect to event stream: )r9streamrr4r% aiter_linesstriprmodel_validate_jsonr>JSONDecodeErrorprintrTimeoutException TimeoutError RequestErrorConnectionError) r,rMinclude_internal_events lock_timeout incl_interr r8rlineeventr"s r$get_workflow_events"WorkflowClient.get_workflow_eventss" 7VG  %##%%% Q!==&,6+7 *<8 )  ++s2()<==!--4!  &%%(09&.&:&:&< )d::<<)(A(U(U$()"', 9& &, )$(#7#7) %(>qc$&P Q ()'=)      >)) ">zlK%% Q%(KA3&OPP QK&%%%%%s3%GC5GF<E C7 E-E; EC9E GC;GE7D2;C= <D2?EC?3E5G7E9E;G=D2?D/ D* $E*D/ /E3 E>E?EF<E E E EF<E5F'F""F''F<* G5F86G<GG  GGc# [U5nSU0nU(aX6S'UR5IShvN nUR SU3US9IShvN n[ U5 [ R"UR55sSSS5IShvN $![an[SU35eSnAff=fNNfN)!,IShvN (df  g=f7f)a Send an event to the workflow. Args: handler_id (str): ID of the handler of the running workflow to send the event to event (Event | dict[str, Any] | str): Event to send, represented as an Event object, a dictionary or a serialized string. step (Optional[str]): Step to send the event to (optional, defaults to None) Returns: SendEventResponse: Confirmation of the send operation z,Error while serializing the provided event: Nrxstepr`rO) rPrQr4r9rTr%rr=r>) r,rMrxr|serialized_eventr"rWr8rs r$ send_eventWorkflowClient.send_events" Q/?/F )01A'B #' ##%%#[[8J<)@|[TTH ' 1$33HMMOD &%%  QKA3OP P Q &T&%%%sxC B#CB2CB8 B42B8 C B6 C B/B**B//C4B86C8C>C ? C Cc@# URU5IShvN $N7f)z& Deprecated. Use get_handler instead. N) get_handler)r,rMs r$ get_resultWorkflowClient.get_result#s%%j1111s c2# UR5IShvN nURSUUS.S9IShvN n[U5 [R"UR 55sSSS5IShvN $N_NFN !,IShvN (df  g=f7f)a9 Get all the workflow handlers. Args: status (list[Status] | None): List of statuses (e.g. "running", "completed", etc. ) to filter by. Defaults to None. workflow_name (list[str] | None): List of workflow names to filter by. Defaults to None. Returns: HandlersListResponse: List of workflow handlers. Nz /handlers)statusrVrf)r9r<r%r r=r>)r,rrVr8rs r$ get_handlersWorkflowClient.get_handlers)sz##%%#ZZ$%2(H ( 1'66x}}G&%%&%%%sTBA7BA=A92A=% B1A;2B9A=;B=BB  BBc4# UR5IShvN nURSU35IShvN n[U5 [R"UR 55sSSS5IShvN $N`NFN !,IShvN (df  g=f7f)z Get a single workflow handler by identifier. Args: handler_id (str): ID of the handler associated with the workflow run Returns: HandlerData: Handler metadata persisted by the server. N /handlers/)r9r<r%r r=r>)r,rMr8rs r$rWorkflowClient.get_handlerBsh##%%#ZZ*ZL(ABBH ' 1--hmmo> &%%B&%%%sTBA8BA>A:2A>& B2A<3B:A><B>BB  BBcJ# UR5IShvN nURSUS3SU(aSOS0S9IShvN n[U5 [R"UR 55sSSS5IShvN $NkNFN !,IShvN (df  g=f7f)z Stop and cancel a workflow run. Args: handler_id (str): ID of the handler associated with the workflow run purge (bool): Whether or not to delete the run also from the persistent storage. Defaults to false Nrz/cancelpurger^r_r)r9rTr%rr=r>)r,rMrr8rs r$cancel_handlerWorkflowClient.cancel_handlerRs##%%#[[ZL05g>)H ( 1(77 H&%%&%%%sTB#BB##B B2B 1 B#=B>B#B B# B B  B B#)r2r-)r-zhttpx.AsyncClient)r2str)r-zhttpx.AsyncClient | Noner2 str | None)returnz AsyncIterator[httpx.AsyncClient])rr)rr)NNN) rVrrMrrKz"StartEvent | dict[str, Any] | NonerLzContext | dict[str, Any] | Nonerr )F)rMrrtboolrufloatrz/AsyncGenerator[EventEnvelopeWithMetadata, None]r*)rMrrxEvent | dict[str, Any]r|rrr)rMrrr )NN)rzlist[Status] | NonerVzlist[str] | Nonerr F)rMrrrrr)__name__ __module__ __qualname____firstlineno__rr.rr9r@rDrXr[ryr~rrrr__static_attributes__r+r0r$r'r'6s ??    26# !/ ! ! B I""&:>37 +?+?+?8 +? 1 +?  +?`"&:>37 +?+?+?8 +? 1 +?  +?`). :Q:Q"&:Q :Q 9 :Q@ EE&E E  E<2'+*.H#H(H  H2?".3II&*I IIr0r'c[U[5(aU$U(aUR5$[R"US9R5$)N)rx)rRdict model_dumpr from_event)rxrGs r$rPrPfsL%    % %E 2 = = ?r0)rzhttpx.ResponserNoner)rxrrGrrzdict[str, Any]) __future__rrr>typingrrrr contextlibrworkflows.eventsr r workflowsr workflows.protocolr r rrrrr&workflows.protocol.serializable_eventsrrr%r'rPr+r0r$rso#  +. *mImIb 16  ! )-  r0