
    Vh	                         d Z ddlmZ ddlZddlZddlmZmZ ddl	m
Z
 ddlmZ ddlmZ dd	lmZ  eed
          Zde
fdZdS )z
Launch command.
    )partialN   )SubmitRulesupdate_from_args)DecoratedMain)Shepherd)
simple_log)reliable_rmtreezLaunch:mainc                    t          |t                    }|                                }t          ||            t	                      }t          ||            |                    | j                  }t          d|            |                                 | j        rV|j	        t          d           n=|
                                rt          d           n|j	                                         d S | j        rt          d           |j	        |                    |j	                   |                                 t          d           |j        j                                        rt#          |j        j                   d |_	        |                    |||           |                                 | j        s| j        rd}d }d}	 	 |j                                        r |t+          j        d	d
dd|j        g          }|
                    d          r%t          d|                                           d}nt1          j        d           n!# t4          $ r d}t          d           Y nw xY w|r*|rt1          j        d           |                                 | j        r@|s@|j	        ;t          d|j	        j                    |j	                                         d S d S d S d S # |r*|rt1          j        d           |                                 | j        r?|s>|j	        8t          d|j	        j                    |j	                                         w w w w xY wd S )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	            Q/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/dora/launch.pylaunch_actionr3      s   #&&&H!!##EUD!!!MMEUD!!!((33E   !!!OO{ 934444]]__ 	$%%%%Iz &'''9   +++#$$$8?!!## 	-EHO,,,	ueU333OOy 'DK '	'9##%% T,*>#%8VT5$	,R#S#SL==)) <ekkmmLLLD
2   	1 	1 	1D/00000	1  $ "JqMMM!!###{ '4 '9(OUY=MOOPPPI$$&&&&&' ' ' '((  $ "JqMMM!!###{ '4 '9(OUY=MOOPPPI$$&&&&' '(/' 's,   B	I K3 I74K3 6I77K3 3A6M))__doc__	functoolsr   
subprocessr"   r%   confr   r   r   r   shepr   r   r	   utilsr
   r3        r2   <module>r<      s                / / / / / / / /                   " " " " " "gj)$$9'm 9' 9' 9' 9' 9' 9'r;   