
    i                    \   S SK Jr  S SKJrJr  S SKJr  S SKJr  \S   r	S!S jr
 " S S\5      r " S	 S
\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r/ SQrg )"    )annotations)AnyLiteral)	BaseModel)EventEnvelopeWithMetadata)running	completedfailed	cancelledc                    U S;   $ )N>   r
   r   r	    )statuss    U/home/james-whalen/.local/lib/python3.13/site-packages/workflows/protocol/__init__.pyis_status_completedr      s    999    c                  p    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S	'   S
\S'   S\S'   S\S'   S\S'   Srg)HandlerData   str
handler_idworkflow_name
str | Nonerun_iderrorz EventEnvelopeWithMetadata | NoneresultStatusr   
started_at
updated_atcompleted_atr   N__name__
__module____qualname____firstlineno____annotations____static_attributes__r   r   r   r   r      s5    O,,NOr   r   c                       \ rS rSr% S\S'   Srg)HandlersListResponse   zlist[HandlerData]handlersr   Nr    r   r   r   r(   r(      s    r   r(   c                       \ rS rSr% S\S'   Srg)HealthResponse"   zLiteral['healthy']r   r   Nr    r   r   r   r,   r,   "   s    r   r,   c                       \ rS rSr% S\S'   Srg)WorkflowsListResponse&   z	list[str]	workflowsr   Nr    r   r   r   r/   r/   &   s    r   r/   c                       \ rS rSr% S\S'   Srg)SendEventResponse*   zLiteral['sent']r   r   Nr    r   r   r   r3   r3   *   s    r   r3   c                       \ rS rSr% S\S'   Srg)CancelHandlerResponse.   zLiteral['deleted', 'cancelled']r   r   Nr    r   r   r   r6   r6   .   s    ++r   r6   c                  *    \ rS rSr% S\S'   S\S'   Srg)WorkflowSchemaResponse2   zdict[str, Any]startstopr   Nr    r   r   r   r9   r9   2   s    
r   r9   c                       \ rS rSr% S\S'   Srg)WorkflowEventsListResponse7   zlist[dict[str, Any]]eventsr   Nr    r   r   r   r>   r>   7   s      r   r>   c                       \ rS rSr% S\S'   Srg)WorkflowGraphResponse;   WorkflowGraphNodeEdgesgraphr   Nr    r   r   r   rB   rB   ;   s    !!r   rB   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S	rg
)WorkflowGraphNode?   r   idlabel	node_typer   title
event_typer   Nr    r   r   r   rG   rG   ?   s    GJNr   rG   c                  *    \ rS rSr% S\S'   S\S'   Srg)WorkflowGraphEdgeG   r   sourcetargetr   Nr    r   r   r   rO   rO   G   s    KKr   rO   c                  *    \ rS rSr% S\S'   S\S'   Srg)rD   L   zlist[WorkflowGraphNode]nodeszlist[WorkflowGraphEdge]edgesr   Nr    r   r   r   rD   rD   L   s    """"r   rD   )r   r   r(   r,   r/   r3   r6   r9   r>   rB   rG   rO   rD   N)r   r   returnbool)
__future__r   typingr   r   pydanticr   &workflows.protocol.serializable_eventsr   r   r   r   r(   r,   r/   r3   r6   r9   r>   rB   rG   rO   rD   __all__r   r   r   <module>r^      s    "   L
 
>	?:	) 	 9  Y I 	 ,I ,Y 
! !"I "	 	 
#Y #
r   