+
    i                    z   ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIHt ]! ]4      P                  4       P                  ^,          t]! ]4      ]P                  9  d#   ]P                  P                  ^ ]! ]4      4       ^ RIHtHtHt ^ RIHtHtHtHtHtHt ^ RIHtHt ^ RIHt R tR	 t ]!R
8X  d
   ] ! 4        R# R# )    )annotationsN)Path)DB_PATHinit_db	fetch_one)create_projectcreate_scenecreate_taskmark_task_submittedmark_task_submission_failedupdate_task_from_callback)_extract_assets_authorized)choose_endpointc                    \         P                  ! 4       '       d   \         P                  ! 4        R FJ  p \        \	        \         4      V ,           4      pVP                  4       '       g   K:  VP                  4        KL  	  \        4        R# )-walN)r   z-shm)r   existsunlinkr   strr   )suffixps     scripts/validate_reliability.pyreset_dbr      sQ    ~~"W&'88::HHJ # I    c                    \        4        \        R RR4       \        RRRR R^RRR	R
R^RR/4       \        RRRR/4      p \	        V RRRRRRRRR//4       \        RV 34      p\        RRRR/4      p\        VRRRR4       \        RV34      pRRRRR R!R"R#R$R%R&R'R(R)R*R+/.//p\        V4      p\        WT4       \        V4      p\        Wd4       \        R,V34      R-,          p\        R.V34      R-,          pR\        RR/4      R/\        RR//4      R0\        RR0/4      R1\        RRR2R3/4      /p	R4p
 \        RR5/4       \        P                  ! \        P                  \        \         R6,          R7,          4      ./ \"        P$                  CR8R9/C\        P&                  \        P&                  ^R:7      pVP(                  RJ9   p\+        \,        P.                  ! R!R3R;VR<VR=VR>VR?V	R@V
RARBVP(                  RCVP0                  P3                  RDRERF7      RG,          //RH^RI7      4       R4#   \         d   p\        T4      p
 R4p?ELR4p?ii ; i)K	proj_demozDemo ProjectzReliability validationscene_idscene_demo_001
project_idordering	narrationnvisual_promptvtarget_duration
scene_typetext
text2videopromptdemokling_demo_task_001req_demo_001
request_iddatatask_idtask_status
processingz6SELECT task_status FROM tasks WHERE task_id_internal=?badzHTTP 429quota_or_concurrencyi  ztoo many requestszGSELECT task_status, task_status_msg FROM tasks WHERE task_id_internal=?succeedtask_status_msgoktask_resultvideosidvid_001urlzhttps://example.com/video.mp4watermark_urlz https://example.com/video_wm.mp4duration5z9SELECT COUNT(*) AS cnt FROM assets WHERE source_task_id=?cntzZSELECT COUNT(*) AS cnt FROM task_events WHERE task_id_internal=? AND event_type='callback'	image_ref
continuityextendextend_flagTNweirdserverzcallback_receiver.pyKLING_CALLBACK_SHARED_SECRETzdemo-secret)envstdoutstderrtimeoutreturned_statusfailed_submission$asset_count_after_duplicate_callback-callback_event_count_after_duplicate_callbackroutesunknown_scene_type_errorcallback_receiver_direct_start
returncoderI   zutf-8ignore)errors:N   NF)ensure_asciiindent)r   N)r   r   r	   r
   r   r   r   r   r   r   	Exceptionr   
subprocessrunsys
executableROOTosenvironPIPErR   printjsondumpsrI   decode)r/   row1	task_failrow2payloadinternal	internal2asset_countevent_count	routes_okunknown_erroreproc	direct_oks                 r   mainrr      sR   J;0HI*-l;zRST_`cdstw  yJ  KL  MY  Z`  a  b*L8V:LMG!6Vdekmv  xM  N[  \h  mi  Ij  kMPWzZD,lXe<LMI	:7MsTgh^aj`lmD.}YGXY]^kmux|  ~G  HM  Nm  n}  ~`  ak  lo  xp  wq  mr  sG(1HH&)'2II'WZbYdefklKx  |D  {F  G  HM  NK 	f 56_l;%?@o|L&AB/<}T"JK	I Mg./ >>3>>3thAW/W+XY  `\bdblbl  `\  oM  N[  `\  eo  et  et  }G  }L  }L  VW  XD9,I	$**d4T.7)"M(<(TXT_T_TfTfgnwTf  UA  BF  UG  +H	 !	% 	&  As   2H( (I	3II	__main__)"
__future__r   rb   r^   rY   r[   pathlibr   __file__resolveparentsr]   r   pathinsert
scripts.dbr   r   r   scripts.repositoryr   r	   r
   r   r   r   server.callback_receiverr   r   scripts.scene_routerr   r   rr   __name__ r   r   <module>r      s    "  	  
 H~''*t9CHHHHOOAs4y! 2 2 V  V A 0,&^ zF r   