
    įg                         d dl mZ d dlmZmZmZ d dlmZ d dlm	Z
 d dlmZ d dlmZ  eddd	      Zej                   d
edededededeeef   dededededefd       Zy)    )Celery)ListDictOptional)HybridSearchN)	Documents)Sessiontaskszredis://localhost:6379/0)brokerbackenddocument_pathdocument_namesanitized_namedocument_url
upload_dirmetadata	user_codecollection_namefolder_namedoc_idreturnc
                    t        j                         }
	 t        |||      }|j                  | ||d ||       |j	                  |      }|
j                  t              j                  t        j                  |	k(        j                         }t        |       |r7||_        ||_        d|_        |
j                          |
j                  |       nd|	 d|
j!                          S 	 |
j!                          y# t"        $ r8}|
j%                          dt'        |       cY d }~|
j!                          S d }~ww xY w# |
j!                          w xY w)NReadyzDocument with doc_id z not found.zError processing document: z Document processed successfully.)dbaseSessionLocalr   upsert_documentget_document_uuidqueryr   filterr   firstprintdoc_urldocument_uuid
doc_statuscommitrefreshclose	Exceptionrollbackstr)r   r   r   r   r   r   r   r   r   r   dbhsr#   update_statuses                  (/var/www/html/answerous/celery_worker.pyprocess_document_celeryr0      s$    $$&B/9kB 	=-xYcd,,^< +2293C3Cv3MNTTVm$0M!*7M''.M$IIKJJ}%*6(+> 	
 & 	
-  6
,SVH55 	
6
 	
s0   C C9 9	D:D5D: D= 5D::D= =E)celeryr   typingr   r   r   dependencies.HybridSearchr   db_config.databasedatabaser   db_config.modelsr   sqlalchemy.ormr	   
celery_apptaskr*   intr0        r/   <module>r=      s     ' ' 2 " & "%&
 (.(.(. (. 	(.
 (. 38n(. (. (. (. (. 	(. (.r<   