
    _j                         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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:8023zoutput/intro/intro.mp4zoutput/footage/footage.mp4zoutput/final.mp4zlog/final-intent.jsonzlog/final-render.json@d0b43671b1ed06396b8a3e61b462d7d885a8ae1eeeab5112eb70eb0ef812245b@7fb56d54eb2ebb9a3efda7989e2cd975fd810467d28152aa3fc5ab7a1502d09fc                      t           j                            t           j        j                                                                      dd          S )Nz+00:00Z)dtdatetimenowtimezoneutc	isoformatreplace     work/render/run_final.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          j        t          dz                                            } | d         t          k    r| d         dk    r| d         dk    sJ t          t                    t          k    rt          t                    t          k    sJ t          j        t          dz                                            d         sJ t          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                    t          t                     ddddddd	}d|vsJ 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=t;          j        d'           t          d|z             }|
                    d          d&v =|
                    d          d(k    rht'          t>          dt          j        t          d)d*||t%                      d+           tA          t          |
                    d                              |
                    d,i           
                    d          du rt                                           sJ t          t                     }
t          j        tC          j"        d-d.d/d0d1d2d3t          t                     gddd4          j#                  }i d5dd6t          j        dt          dd7d8ddd*d9t          d:t          d|d;t          t                     d<|
d=t           $                                j%        d>|d?d*d@|dAt%                      }t'          t>          |           tM          t          j        d7|t           $                                j%        |
dBd*C                     d S )DNz.ownership-lock.jsonrun_idownerzorostatusmain_session_pipelinezlog/intro-render.jsonverifiedzlog/footage-render.jsonz/healthok
h264_nvencTjob_idz/v1/huyenan-render-final/jobs/z/v1/huyenan-render-final/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      @S  @S  @S  GH  T^  _`  ae  Tf  Tf  @S  kl  kp  kp  qy  kz  kz  ~R  kR  kR  AB  kR  kR  kRr   r-   i  i8  p4   )	intro_video_pathfootage_video_pathoutput_video_pathfpswidthheightvideo_encoderpresetcqmain_audio_path   creating)schema_version
project_idr9   r<   intro_sha256footage_sha256payload
created_atzContent-Typezapplication/jsonPOST)dataheadersmethod<   r.   id	submitted)r<   rA   submitted_atrD      	completedfailedF)rZ   r[   r9   r<   r>   rA   endpoint_response	failed_atverification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checkrZ   r[   awaiting_visual_qatechnical_verifiedr\   r]   output_pathoutput_sha256output_size_bytesprobemain_audio_path_sentrk   completed_at)r<   rA   bytesr   )r!   )'r'   r4   ROOT	read_textRUNr   INTROIHFOOTAGEFHr7   INTENTexistsrG   rH   strOUTnamer
   r+   r0   r1   Requestr3   r(   encoder2   r   r   timesleepRECEIPTRuntimeError
subprocessrunstdoutstatst_sizeprint)lockhealthintentjidjoblistingrB   r^   reqr6   r   rx   recs                r   mainr      s>	   
j$--88::;;4>SVCVCV[_`g[hjp[p[puy  {C  vD  F]  v]  v]  v]  v]  eh  in  eo  eo  qs  es  es  x{  |C  xD  xD  FH  xH  xH  xH  xH  PT  PZ  \`  ax  \x  [C  [C  [E  [E  PF  PF  GQ  PR  IR  IR  IR  Z^  Zd  fj  kD  fD  eO  eO  eQ  eQ  ZR  ZR  S]  Z^  S^  S^  S^IfX.449MQU9U9U9U9U
MMOO R4:f&6&6&8&899FfX>N#SVWwx{W{S|S|ss
-
.
.'jY`aeNfNf4sGKKr4J4J4Jlst  @S  @S  LP  @S  @S  @S  uS  uS  uS!%jjc'll_bcf_g_gnpy}  HL  ]i  sw  }  @  @'  HY  ah  Hh  Hh  Hh  Hh$)S*dfxz  FM  [^  [`  [`  
a  
a&  bh  io  pv  bw  bw  bw  |B  |J  |R  |R  SW  Xw  Sw  }A  }G  HO  }P  }P  }W  }W  }Y  }Y  cq  rD  bE  MS  |R  |T  |T  x{~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CHhilHlDmDmswwx000GGH{""6'ASWS\fis{  HM  WZ  or  B  D  D  3E  3E  $F  $F  $F  MY  Z]  ^a  ^e  ^e  fn  ^o  ^o  Zp  Zp  Mq  Mq  Gqr""&&z22d::szz||:::cRUhhA]a]ghrhv  yB  CG  HO  P_  `H  IN  OU  VY  Z]  V^  V^  x_  os  y}  DH  iI  iI  iI  iP  ^Q  ^QW\ bq  bdi  b  bXFZ  b[opt  bu  AF  b  GU  VX  b  Yi  jl  b  mu  vy  b  zG  HK  LO  HP  HP  b  Q`  ab  b  cv  wz  w  w  wA  wA  wI  b  JQ  RW  b  Xn  ot  b  uH  IL  b  M[  \_  \a  \a  b  ci  jq  ru  cv  cv  cv  w|  }A  }G  Rf  ps  |  |D  |D  |F  |F  |N  XY  HZ  HZ  hm  }n  }n  }n  wo  wo  wo  wo  wos   'LL	L	__main__)pathlibr   r	   r   r   r'   r   r   urllib.requestr0   r|   r~   r3   r   r   r   r   r   r   r   r
   r   r+   r7   r   __name__r   r   r   <module>r      sP         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
##D1M,MGRVWiRicqu  wN  rNjp  W[  \s  Ws  OVE  JLb S S S  
l l lT T To o o Zr   