3 D^< @sFddlZddlZddlZddlZddlZddlZGdddejZdS)NcsDeZdZfddZddZddZddZd d Zd d ZZ S) Executorcstt|j|dS)N)superr__init__)selflog) __class__n/home/psgendb/BIRCHDEV/pkg/SPAdes-3.15.4/linux-x86_64/share/spades/spades_pipeline/executors/executor_local.pyrszExecutor.__init__cCs<x4tt|D]"}||}tjjrhtj||j}tjj |rhd|jkrhd|jkrh|j j d|j qd|jkr|j j d|j |j dkr|j j d|j |j|j |j||j|d|jkr|j j d|j |j||tjj|jksd|jkrtjj|jjdd kr|j j d tjjPqWdS) NZ_startZ_finishz%===== Skipping %s (already processed)z ===== %s started. truez == Running: %s z ===== %s finished. _rz ======= Skipping the rest of SPAdes pipeline (--stop-after was set to '%s'). You can continue later with --continue or --restart-from options )rangelenoptions_storageargs continue_modeget_stage_filename short_nameospathisfilerinfoSTAGE__str__runrm_files check_output touch_file stop_aftersplit)rcommandsnumcommandstage_checkpoint_pathrrr executes2            zExecutor.executecCs`tjjr dSxN|jD]D}tjjtjj|}tjj|rBt j |qtjj |rtj |qWdS)N) rrno_clear_afterZ del_afterrrjoin output_dirisdirshutilrmtreerremove)rr!fpathZ fpath_absrrr r7s    zExecutor.rm_filescCs4x.|jD]$}tjj|stj|jd|qWdS)Nz# finished abnormally: %s not found!) output_filesrrrsupporterrorr)rr!r+rrr rBs  zExecutor.check_outputcCstj||dS)N)commands_parserZwrite_commands_to_sh)rrZ outputfilerrr dump_commandsGszExecutor.dump_commandscCsFtj||j}tjjtjj|s4tjtjj|t|dj dS)Na) rrrrrexistsdirnamemakedirsopenclose)rr!r rrrr rJszExecutor.touch_file) __name__ __module__ __qualname__rr#rrr0r __classcell__rr)rr rs  " r)rr(r- executorsr/rZ ExecutorBaserrrrr  s