
    Ji                    Z   d dl mZ d dlmZmZ d dlmZ d dlmZ ed   Z	d!dZ
 G d de      Z G d	 d
e      Z G d de      Z G d de      Z G d de      Z G d de      Z G d de      Z G d de      Z G d de      Z G d de      Z G d de      Z G d de      Zg dZy )"    )annotations)AnyLiteral)	BaseModel)EventEnvelopeWithMetadata)running	completedfailed	cancelledc                
    | dv S )N>   r
   r   r	    )statuss    m/var/www/html/BankruptcyAI-uat/bankruptcy-ai/venv/lib/python3.12/site-packages/workflows/protocol/__init__.pyis_status_completedr      s    999    c                  h    e Zd ZU ded<   ded<   ded<   ded<   ded<   d	ed
<   ded<   ded<   ded<   y)HandlerDatastr
handler_idworkflow_name
str | Nonerun_iderrorz EventEnvelopeWithMetadata | NoneresultStatusr   
started_at
updated_atcompleted_atN__name__
__module____qualname____annotations__r   r   r   r   r      s5    O,,NOr   r   c                      e Zd ZU ded<   y)HandlersListResponsezlist[HandlerData]handlersNr   r   r   r   r%   r%      s    r   r%   c                      e Zd ZU ded<   y)HealthResponsezLiteral['healthy']r   Nr   r   r   r   r(   r(   #   s    r   r(   c                      e Zd ZU ded<   y)WorkflowsListResponsez	list[str]	workflowsNr   r   r   r   r*   r*   '   s    r   r*   c                      e Zd ZU ded<   y)SendEventResponsezLiteral['sent']r   Nr   r   r   r   r-   r-   +   s    r   r-   c                      e Zd ZU ded<   y)CancelHandlerResponsezLiteral['deleted', 'cancelled']r   Nr   r   r   r   r/   r/   /   s    ++r   r/   c                  "    e Zd ZU ded<   ded<   y)WorkflowSchemaResponsezdict[str, Any]startstopNr   r   r   r   r1   r1   3   s    
r   r1   c                      e Zd ZU ded<   y)WorkflowEventsListResponsezlist[dict[str, Any]]eventsNr   r   r   r   r5   r5   8   s      r   r5   c                      e Zd ZU ded<   y)WorkflowGraphResponseWorkflowGraphNodeEdgesgraphNr   r   r   r   r8   r8   <   s    !!r   r8   c                  @    e Zd ZU ded<   ded<   ded<   ded<   ded<   y)	WorkflowGraphNoder   idlabel	node_typer   title
event_typeNr   r   r   r   r<   r<   @   s    GJNr   r<   c                  "    e Zd ZU ded<   ded<   y)WorkflowGraphEdger   sourcetargetNr   r   r   r   rC   rC   H   s    KKr   rC   c                  "    e Zd ZU ded<   ded<   y)r9   zlist[WorkflowGraphNode]nodeszlist[WorkflowGraphEdge]edgesNr   r   r   r   r9   r9   M   s    """"r   r9   )r   r   r%   r(   r*   r-   r/   r1   r5   r8   r<   rC   r9   N)r   r   returnbool)
__future__r   typingr   r   pydanticr   &workflows.protocol.serializable_eventsr   r   r   r   r%   r(   r*   r-   r/   r1   r5   r8   r<   rC   r9   __all__r   r   r   <module>rP      s    "   L
 
>	?:	) 	 9  Y I 	 ,I ,Y 
! !"I "	 	 
#Y #
r   