+
    -il                        ^ RI Ht ^ RIHt ^ RIHt ^ RIHtHt ^ RI	H
t
HtHt ^ RIHt ^ RIHt R R	 ltRR R lltRR R lltRR R lltRR R lltRR R lltRR R lltRR R lltR
# )    )annotations)Any)KlingConfig)KlingClientKlingClientError)create_taskmark_task_submission_failedmark_task_submitted)validate_payload)QUERY_PATHSc               (    V ^8  d   QhRRRRRRRR/# )   payloaddict[str, Any]callback_url
str | Noneexternal_task_idreturn )formats   "scripts/kling_tasks.py__annotate__r      s*      N * Xb gu     c                <    \        V 4      pVe   WR&   Ve   W#R&   V# )Nr   r   )dict)r   r   r   outs   &&& r   _inject_commonr      s-    
w-C*N#"2Jr   Nc               0    V ^8  d   QhRRRRRRRRRRR	R/# )
r   endpoint_typestrr   r   r   r   r   scene_idr   r   )r   s   "r   r   r      sN     H HS H> HQ[ H  wA H  T^ H  jx Hr   c                   \        \        4       4      p\        WV4      p\        W4       \	        W@Wc4      p VP                  W4      pTP                  R4      ;'       g    / p
\        YzP                  R4      TP                  R4      T4       RTRT/#   \         d=   p	\        T\        T	4      T	P                  T	P                  T	P                  4       h R p	?	ii ; i)Ndatatask_id
request_idtask_id_internalresponse)r   r   r   r   r   postr   r	   r    categorystatus_coderesponse_bodygetr
   )r   r   r   r   r!   clientenrichedr&   r'   er#   s   &&&&&      r   create_kling_taskr0      s    'Fg5EFH]-"8HW;;}7 <<%%2D(((9*=x||L?Y[cd 0*hGG  #$4c!fajj!--YZYhYhis   B C 7CCc               $    V ^8  d   QhRRRRRR/# )r   
query_kindr    urlr   r   r   r   )r   s   "r   r   r   $   s&     C C# CJ C. Cr   c                    \        \        4       4      pT;'       g    \        P                  ! V 4      pV'       g   \	        R V  24      hVP                  VRV  2R7      # )zQuery path not pinned yet for query_)	log_label)r   r   r   r,   
ValueErrorget_url)r2   r3   r-   targets   &&  r   query_task_statusr:   $   sT    'F//KOOJ/F9*FGG>>&fZL,A>BBr   c          
     ,    V ^8  d   QhRRRRRRRRRR/# r   r   r   r   r   r   r!   r   r   )r   s   "r   r   r   ,   sA     ^ ^. ^
 ^eo ^  CM ^  Yg ^r   c                    \        R WW#4      # )
text2videor0   r   r   r   r!   s   &&&&r   create_text_to_videorA   ,   s    \7BR]]r   c          
     ,    V ^8  d   QhRRRRRRRRRR/# r<   r   )r   s   "r   r   r   0   sA     _ _> _ _fp _  DN _  Zh _r   c                    \        R WW#4      # )image2videor?   r@   s   &&&&r   create_image_to_videorE   0   s    ]GCS^^r   c          
     ,    V ^8  d   QhRRRRRRRRRR/# r<   r   )r   s   "r   r   r   4   sA     X X~ XZ Xbl X  @J X  Vd Xr   c                    \        R WW#4      # )omnir?   r@   s   &&&&r   create_omni_videorI   4   s    VW<LWWr   c          
     ,    V ^8  d   QhRRRRRRRRRR/# r<   r   )r   s   "r   r   r   8   sA     c c~ cZ cjt c  HR c  ^l cr   c                    \        R WW#4      # )reference2videor?   r@   s   &&&&r   create_reference_to_videorM   8   s    .GWbbr   c          
     ,    V ^8  d   QhRRRRRRRRRR/# r<   r   )r   s   "r   r   r   <   sA     Z Z Zz Zdn Z  BL Z  Xf Zr   c                    \        R WW#4      # )extendr?   r@   s   &&&&r   create_extend_videorQ   <   s    Xw>NYYr   )NNN)N)
__future__r   typingr   configs.klingr   scripts.kling_clientr   r   scripts.repositoryr   r	   r
   scripts.validatorsr   scripts.query_pathsr   r   r0   r:   rA   rE   rI   rM   rQ   r   r   r   <module>rY      sR    "  % > \ \ / +HC^_XcZ Zr   