§
     ’jH  ã                  ó    — d dl mZ d dlmZ d dlmZmZmZmZm	Z	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 dd	lmZ  G d
„ dee¦  «        ZdS )é    )Úannotations)ÚAny)ÚAuditInspectionAgentÚContractManagementAgentÚInternalDossierReviewAgentÚLegalComplianceAgentÚPaymentSettlementAgentÚProcurementTenderAgentÚProjectPlanningAgentÚTechnicalDeliveryAgent)ÚPostgresClient)ÚHybridSearchService)ÚReviewMemoryServiceé   )ÚOrchestratorIngestionMixin)ÚOrchestratorRoutingMixinc                  ó   — e Zd ZdZd
d„Zd	S )ÚTaskOrchestratorz2Coordinates retrieval and logical-agent execution.Ú
llm_clientr   Úqdrant_storeÚembedding_serviceÚreturnÚNonec           
     óˆ  — || _         || _        t          ||¦  «        | _        t	          ¦   «         | _        t          ¦   «         | _        t          |¦  «        t          |¦  «        t          |¦  «        t          |¦  «        t          |¦  «        t          |¦  «        t          |¦  «        t          |¦  «        dœ| _        d S )N)Úlegal_complianceÚproject_planningÚprocurement_tenderÚcontract_managementÚtechnical_deliveryÚpayment_settlementÚaudit_inspectionÚdossier_review)Ú_qdrant_storeÚ_embedding_servicer   Ú_hybrid_search_servicer   Ú_postgres_clientr   Ú_review_memory_servicer   r   r
   r   r   r	   r   r   Ú_agents)Úselfr   r   r   s       ú6C:\Projects\DSCons\app\agents\orchestration\service.pyÚ__init__zTaskOrchestrator.__init__   s´   € ð *ˆÔØ"3ˆÔÝ&9ØÐ+ñ'
ô '
ˆÔ#õ !/Ñ 0Ô 0ˆÔÝ&9Ñ&;Ô&;ˆÔ#å 4°ZÑ @Ô @Ý 4°ZÑ @Ô @Ý"8¸Ñ"DÔ"DÝ#:¸:Ñ#FÔ#FÝ"8¸Ñ"DÔ"DÝ"8¸Ñ"DÔ"DÝ 4°ZÑ @Ô @Ý8¸ÑDÔDð	
ð 	
ˆŒˆˆó    N)r   r   r   r   r   r   r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r+   © r,   r*   r   r      s0   € € € € € ð =Ð<ð
ð 
ð 
ð 
ð 
ð 
r,   r   N)Ú
__future__r   Útypingr   Úapp.agents.specialistsr   r   r   r   r	   r
   r   r   Úapp.core.postgresr   Ú2app.modules.core.application.hybrid_search_servicer   Ú2app.modules.core.application.review_memory_servicer   Úorchestrator_ingestionr   Úorchestrator_routingr   r   r1   r,   r*   ú<module>r:      s!  ðØ "Ð "Ð "Ð "Ð "Ð "à Ð Ð Ð Ð Ð ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð -Ð ,Ð ,Ð ,Ð ,Ð ,Ø RÐ RÐ RÐ RÐ RÐ RØ RÐ RÐ RÐ RÐ RÐ Rà >Ð >Ð >Ð >Ð >Ð >Ø :Ð :Ð :Ð :Ð :Ð :ð
ð 
ð 
ð 
ð 
ØØñ
ô 
ð 
ð 
ð 
r,   