
    j                     f    d dl Zd dlZd dlmZ d dlmZ d dlm	Z	 e G d de	                      Z
dS )    N)	dataclass)create_ingest_doc_from_dict)	WriteNodec                   0    e Zd Zdej        e         fdZdS )Writer
json_pathsc                 :   g }|D ]z}t           j                            |          }t           j                            |          d         }| j        j        |         }|                    t          |                     {| j        	                    |           d S )Nr   )docs)
ospathbasenamesplitextpipeline_contextingest_docs_mapappendr   dest_doc_connectorwrite)selfr   ingest_docs	json_pathfilenamedoc_hashingest_doc_dicts          l/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/unstructured/ingest/pipeline/write.pyrunz
Writer.run   s    # 	M 	MIw''	22Hw''11!4H"3CHMO:?KKLLLL%%;%77777    N)__name__
__module____qualname__tListstrr    r   r   r   r   	   s5        8afSk 8 8 8 8 8 8r   r   )os.pathr   typingr    dataclassesr   &unstructured.ingest.connector.registryr   'unstructured.ingest.pipeline.interfacesr   r   r#   r   r   <module>r)      s         ! ! ! ! ! ! N N N N N N = = = = = = 8 8 8 8 8Y 8 8 8 8 8r   