
    6_jj                         d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZ	 ed          Z
dZdZe
dz  Ze
dz  Ze
dz  Ze
d	z  Zd
ZdZd Zd Zd Zd Zd Zedk    r e             dS dS )    )PathNzN/data/video-pipeline/HaTramAudio/project/021-Ngay-Toi-Bi-Gach-Ten-Khoi-Gia-Phazrun-20260721T131911Z-ac5d64d1zhttp://192.168.1.104:8024zoutput/final.mp4zoutput/final-upload.mp4zlog/transcode-intent.jsonzlog/transcode-upload.json@2b331a8b7e64352c866ede0215a52f39b344cbc460c3036d967ad7013811a1c0@bb80e97d9adcb0427ea3828449858445323db228cca38f37cdf0446fffefdd6fc                      t           j                            t           j        j                                                                      dd          S )Nz+00:00Z)dtdatetimenowtimezoneutc	isoformatreplace     work/render/run_transcode.pyr
   r
      s5    11;;==EEhsSS
Sr   c                 &   t          j                    }t          | d          5 }|                    d          x}r,|                    |           |                    d          x},d d d            n# 1 swxY w Y   |                                S )Nrbi   )hashlibsha256openreadupdate	hexdigest)phfbs       r   shar      s    
>
1Tll +a66+*qxx{{{166+*+ + + + + + + + + + + + + + +	s   AA44A8;A8c                     |                      | j        dz             }|                    t          j        |dd          dz              |                    |            d S )Nz.tmpF   )ensure_asciiindent
)with_suffixsuffix
write_textjsondumpsr   )r   ots      r   atomicr+      s]    ==&!!!,,tz!VW/X/X/XY]/]"^"^"^_`_h_hij_k_k_k_k_kr   c                     t           j                            t          | z   d          5 }t	          j        |                                          cd d d            S # 1 swxY w Y   d S )N   timeout)urllibrequesturlopenBASEr'   loadsr   )pathrs     r   getr7      sp    nT$Yr22Satz!&&((?S?SSSSSSSSSSSSSSSSSSSs   &AA!$A!c                  	   t          t                    t          k    r4t          j        t
          dz                                            d         sJ t          d          } | d         dk    r
| d         du sJ t          	                                rGt          j        t                                                    }|d         }t          d	|z             }nt          d
          }t          |t                    r|                    dg           n|}d |D             rJ t          t                    t          t                    dddddddd	}dt
          j        t          dt           t          |t#                      d}t%          t          |           t&          j                            t,          d
z   t          j        |                                          ddid          }t&          j                            |d          5 }t          j        |                                          }d d d            n# 1 swxY w Y   |                    d          p|                    d          }|sJ |                    d|t#                      d            t%          t          |           |                    d          d!v r=t9          j        d"           t          d	|z             }|                    d          d!v =|                    d          d#k    r/t=          t          |                    d                              |                    d$i           }	|	                    d          du rR|	                    d%          du r;t          	                                r"t                                          j         dk     sJ t          j        tC          j"        d&d'd(d)d*d+d,t          t                    gddd-          j#                  }
dt
          j        t          d#dt           t          |t          t                    t          t                    t                                          j         d|
|t#                      d.}t%          tH          |           tK          t          j        d#d|t                                          j         |d/         d0d1                     d S )2Nzlog/final-render.jsonverifiedz/healthstatusok
h264_nvencTjob_idz"/v1/huyenan-transcode-upload/jobs/z!/v1/huyenan-transcode-upload/jobsjobsc                 j    g | ]0}t          |t                    |                    d           dv .|1S )r:   queuedrunning)
isinstancedictr7   ).0xs     r   
<listcomp>zmain.<locals>.<listcomp>   s      DW  DW  DW  KL  Xb  cd  ei  Xj  Xj  DW  op  ot  ot  u}  o~  o~  BV  oV  oV  EF  oV  oV  oVr   i /i ʚ;i  i8  r-   `   F)	input_video_pathoutput_video_pathtarget_output_bytesmax_output_byteswidthheightfpsaudio_bitrate_kbps	overwrite   creating)schema_version
project_idrun_idr:   source_canon_sha256master_sha256payload
created_atzContent-Typezapplication/jsonPOST)dataheadersmethod<   r.   id	submitted)r:   r=   submitted_atr@      	completedverificationunder_one_gbffprobez-verrorz-show_entrieszfformat=duration,size:stream=index,codec_type,codec_name,width,height,r_frame_rate,sample_rate,channelsz-ofr'   )capture_outputtextcheck)rT   rU   rV   r:   r9   rW   rX   r=   output_pathoutput_sha256output_size_bytesrf   probeendpoint_responsecompleted_atrm   )r:   r9   r=   bytesr   )r!   )&r   INMASTERr'   r4   ROOT	read_textr7   INTENTexistsrC   rD   strOUTnameRUNCANONr
   r+   r0   r1   Requestr3   r(   encoder2   r   r   timesleepRuntimeErrorstatst_size
subprocessrunstdoutRECEIPTprint)r   intentjidjoblistingr>   rY   reqr6   verro   recs               r   mainr      s-   BDJ-D(D'O'O'Q'QRRS]^adenaoao_`wx  zB  xC  EI  xI  xI  NO  P\  N]  ae  Ne  Ne  Ne  Ne
MMOO R4:f&6&6&8&899FfX>N#SVW{|W  TA  TAss
1
2
2'R\]deiRjRj8wF28N8N8Npw4  DW  DW  PT  DW  DW  DW  yW  yW  yW!"gg#c((Yb  wA  JN  X\  ce  {}  JO  P  P'  jk  y}  yB  LO  Yc  z  PV  ah  vy  v{  v{  X|  X|  QW  }C  DJ  KQ  }R  }R  }R  W]  We  Wm  Wm  nr  sV  nV  \`  \f  gn  \o  \o  \v  \v  \x  \x  BP  Qc  Ad  lr  Wm  Ws  Ws  SV~c"--Ktz!&&((7K7K3KKKKKKKKKKKKKKK	ggh(3774==#FMMKadtwtytyBzBz4{4{4{  }C  DJ  KQ  }R  }R  }R
wwx000BCHlmpHpDqDqswwx000GGH{""c#''(:K:K6L6L)M)M#MWW^Bswwz':':d'B'Bsww~G^G^bfGfGfknkukukwkwGf|  }E  }E  }G  }G  }O  P]  }]  }]  }]  }]z*.)D  Jr  sx  y  @C  DG  @H  @H  "I  Y]  cg  nr  s  s  s  z  {  {  RS  ae  aj  tw  AL  X\  sx  IO  Y\  kn  or  ks  ks  DG  HK  DL  DL  ad  ai  ai  ak  ak  as  CG  PU  jm  }@	  }B	  }B	  @C	  @C	  |  D	J	  K	R	  S	V	  D	W	  D	W	  D	W	  X	]	  ^	b	  ^	h	  s	~	  J
N
  X
[
  d
g
  d
l
  d
l
  d
n
  d
n
  d
v
  @C  DS  @T  i	U  i	U  ch  ^	i  ^	i  ^	i  X	j  X	j  X	j  X	j  X	js   'H??II__main__)pathlibr   r	   r   r   r'   r   r   urllib.requestr0   ru   r|   r3   rs   rz   rw   r   rt   r}   r
   r   r+   r7   r   __name__r   r   r   <module>r      s~         A A A A A A A A A A A A A A A A A A A A A A A A	T
Z[[`\_  Fa  AE  ei  j|  e|  bd  AE  F_  A_  }@  gk  lG  gG  `f  PT  Up  Pp  HO  xz  qw  AC  {@ S S S  
l l lT T Tj j j Zr   