
    Ej                         S SK JrJr  S SKJr  S SKJrJrJr  S SK	r	S SK
r
S SKrS SKrS SKJr  \" SS9r " S S	\5      r\R#                  S
5      S\4S j5       rg)    )FastAPIHTTPException)	BaseModel)ListDictAnyN)transform_rowzAI Land Pipeline API)titlec                   0    \ rS rSr% \\\\4      \S'   Sr	g)PipelineRequest   raw_data N)
__name__
__module____qualname____firstlineno__r   r   strr   __annotations____static_attributes__r       &/var/www/html/banglarbhumi/land_api.pyr   r      s    4S>""r   r   z/land_checkreqc                     U R                    Vs/ s H  n[        U5      PM     nn[        SSSS9 n[        R                  " UUSSS9  S S S 5        [        S5        [        R                  " S	S
/SSS9nUR                  S:w  a  [        SUR                  S9e[        R                  " S5      nU(       d
  [        SSS9e[        U[        R                  R                  S9n[        R                  " S	SU/SSS9nUR                  S:w  a  [        SUR                  S9e[        USSS9 n[        R                   " U5      nS S S 5        Sn	WR#                  5        H  u  pUR%                  S5      S:X  a  Sn	  O   U	UUS.$ s  snf ! , (       d  f       GNC= f! , (       d  f       N]= f! [&         a  n[        S[)        U5      S9eS nAff = f)Nzformatted_output.jsonwzutf-8)encoding   F)indentensure_asciiu!   ✅ formatted_output.json createdpython3zmatch_pipeline.pyT)capture_outputtextr   i  )status_codedetailzgrouped_result_*.jsonzNo grouped result file found)keyzpush_ai_status.pyrstatusREJECTED)successgrouped_result_filedata)r   r	   openjsondumpprint
subprocessrun
returncoder   stderrglobmaxospathgetctimeloaditemsget	Exceptionr   )r   rowtransformed_datafmatch_resultgrouped_fileslatest_filepush_resultfinal_result
is_success_itemes                r   run_pipelinerI      s   j
 ||
# ## 	 
 )3AQII "	 B 	12
 "~~+,
 ""a'#**  		"9:5 
 -RWW-=-=>
 !nn#
  
 !!Q&"))  +sW599Q<L 6 
#))+GAxx!Z/"
	 , "#. 
 	
u
 BA@ 650  
q6
 	

sW   F) FF) F
C F) *F?F) F) 
FF) 
F&"F) )
G3GG)fastapir   r   pydanticr   typingr   r   r   r0   r-   r4   r6   fetch_land_datar	   appr   postrI   r   r   r   <module>rP      s`    *  " "    	 **+#i # -l
o l
 l
r   