
    =h'                     .    d dl mZ d dlZ G d de      Zy)    )WorkflowRunnerBaseNc                   ,     e Zd Zd fd	Zd Zd Z xZS )SplitByRefRunnerc	                 @    t         	|   |||||||dg ddd|       y )NzsplitByRef.py)z-iz-oz-sz-tz--input_bamz--output_dirz--sample_idz	--threadsbamT)loggermanifest_list
input_pathoutput_pathadditional_argsthreadsstepnamesoftware_nameunneeded_argsoutput_typerescan_outputmode)super__init__)
selfr   r	   r
   r   r   r   r   r   	__class__s
            F/mounts/lovelace/software/shotgun-workflow/dev/modules/split_by_ref.pyr   zSplitByRefRunner.__init__   s9    '!#+)m 	 	
    c           	      |    |D ])  }| j                   j                  |d   |d   d d d d       + | j                  r|S y )Nidoutput1)r   input1input2r   output2)input_file_listappendleaf)r   prev_step_fileslines      r   find_input_filesz!SplitByRefRunner.find_input_files   sN    #D  ''4jy/)  $ 99""r   c                     | j                   D ]c  }| j                  d|d    d| j                   d|d    d| j                   g}| j                  j                  dj                  |             e y )Nz--input_bam r   z--output_dir z--sample_id r   z
--threads  )r    r   r   r   command_queuer!   join)r   itemcmds      r   build_command_queuez$SplitByRefRunner.build_command_queue#   s|    ((D""tH~./ 0 012tDzl+T\\N+C %%chhsm4 )r   ) r-      r-   N)__name__
__module____qualname__r   r%   r,   __classcell__)r   s   @r   r   r      s    
 
5r   r   )modules.software_baser   osr    r   r   <module>r6      s    4 	)5) )5r   