
    ]i	                         S r SSKJr  SSKrSSKrSSKJrJr  SSK	J
r
  SSKJr  SSKJr  SS	KJr  \" \S
5      rS\
4S jrg)z
Launch command.
    )partialN   )SubmitRulesupdate_from_args)DecoratedMain)Shepherd)
simple_log)reliable_rmtreezLaunch:mainc                 ~   [        U[        S9nUR                  5       n[        X05        [	        5       n[        X@5        UR                  U R                  5      n[        SU 35        UR                  5         U R                  (       aU  UR                  c  [        S5        g UR                  5       (       a  [        S5        g UR                  R                  5         g U R                  (       a  [        S5        UR                  b  UR                  UR                  5        UR                  5         [        S5        UR                  R                  R!                  5       (       a  [#        UR                  R                  5        S Ul	        UR%                  XSU5        UR                  5         U R&                  (       d  U R(                  (       Ga3  SnS nSn  UR                  R!                  5       (       a(  Uc%  [*        R,                  " S	S
SSUR                  /5      nUR                  S5      (       a  [        SUR/                  5       5        SnO[0        R2                  " S5        M  U(       a-  U(       a  [0        R2                  " S5        UR7                  5         U R(                  (       aS  U(       dK  UR                  b=  [        SUR                  R8                   35        UR                  R                  5         g g g g g ! [4         a    Sn[        S5         Nf = f! U(       a-  U(       a  [0        R2                  " S5        UR7                  5         U R(                  (       aS  U(       dK  UR                  b=  [        SUR                  R8                   35        UR                  R                  5         f f f f = f)N)logzFetched sheep z!Could not cancel non existing jobzJob is not runningzCanceling current job...zDeleting XP folder...FTtailz-n200z-fforcez"Remote process finished with state   zKeyboardInterrupt received...   z"attach is set, killing remote job )r   r   get_slurm_configr   r   get_sheep_from_argvargvupdatecanceljobis_doneclearcancel_lazycommitxpfolderexistsr
   maybe_submit_lazyr   attachspPopenstatetimesleepKeyboardInterruptkilljob_id)	argsr   shepherdslurmrulessheepdonetail_processwaits	            H/mnt/rpi/tmp/demucs-venv-sys/lib/python3.13/site-packages/dora/launch.pylaunch_actionr3      s   #&H!!#EU!MEU!((3E. !OO{{9934
 		 ]]__$% 	 IIzz&'99   +#$88??!!##EHHOO,	uU3OOyyDKKK	'99##%%,*>#%88VT5$		,R#SL==))<ekkmLD

2  JJqM!!#{{499(<UYY=M=M<NOPII$$& ) $({-   ! 	1D/0	1 JJqM!!#{{499(<UYY=M=M<NOPII$$& ) $({s2   A:L L" L LL" LL" "BN<)__doc__	functoolsr   
subprocessr"   r%   confr   r   r   r   shepr   r   r	   utilsr
   r3        r2   <module>r<      s<       /    "j)$9'm 9'r;   