o
    a-g+                     @   sz   d dl mZ d dlmZmZmZ d dlmZ eddddZej	de
de
d	e
d
e
de
dee de
de
dee fddZdS )    )Celery)ListDictOptional)HybridSearchtaskszredis://localhost:6379/0)brokerbackenddocument_pathdocument_namesanitized_namedocument_url
upload_dirusercollection_namefolder_namenew_documentc
                 C   s   t ||tj}
|
| ||d || |
|}tttj	|	j	k
 }||_||_d|_t  tttj	|	j	k
 }t| d S )NReady)r   folderr   upsert_documentget_document_uuiddbquery	Documentsfilterdoc_idfirstdoc_urldocument_uuid
doc_statuscommitrefresh)r
   r   r   r   r   metadatar   r   r   r   hsr   update_statusupdated_data r&   9/var/www/html/answerous_api/dependencies/celery_worker.pyprocess_document_celery   s   
r(   N)celeryr   typingr   r   r   dependencies.HybridSearchr   
celery_apptaskstrr(   r&   r&   r&   r'   <module>   s    <