o
    cþÝiî  ã                   @   sN   d Z ddlZddlmZ ddlmZ ddlmZ deded	ed
dfdd„Z	dS )u"   Phase 5ï¼šè§¦å‘çŸ¥è¯†å›¾è°±æž„å»ºé    N)Úlogger)ÚKnowledgeBaseClienté   )ÚImportStateÚstateÚbase_urlÚtokenÚreturnc                 C   sª   |   d¡rt d¡ d S |  ¡ }|stdƒ‚t||d}t |j|d d¡}|r=| 	d¡r=t d|› d¡ |  
d¡ d S |rD| 	d	¡nd
}t d|› ¡ td|› ƒ‚)NÚ5u   Phase 5 å·²å®Œæˆï¼Œè·³è¿‡u&   kb_id æœªæ‰¾åˆ°ï¼Œè¯·å…ˆæ‰§è¡Œ Phase 1)r   Úapi_key)Úkb_idÚdocument_idsÚsuccessu>   âœ“ Phase 5 å®Œæˆï¼šçŸ¥è¯†å›¾è°±æž„å»ºä»»åŠ¡å·²è§¦å‘ (kb_id=ú)ÚerrorÚunknownu    çŸ¥è¯†å›¾è°±æž„å»ºè§¦å‘å¤±è´¥: u   Phase 5 å¤±è´¥: )Úis_phase_doner   ÚinfoÚ	get_kb_idÚRuntimeErrorr   ÚasyncioÚrunÚtrigger_graph_buildÚgetÚmark_phase_doner   )r   r   r   r   ÚclientÚresultr   © r   úS/lsinfo/ai/hellotax_ai/data_center/backend/./app/services/import_kb/phase5_graph.pyÚ
run_phase5
   s   

r   )
Ú__doc__r   Úlogurur   Ú5app.services.tax_data_processor.knowledge_base_clientr   r   r   Ústrr   r   r   r   r   Ú<module>   s    