Commit c11b063d authored by Fidel Alfaro Almagro's avatar Fidel Alfaro Almagro
Browse files

Update bb_pipeline_diff_queue_joint.py

parent 202ec8be
......@@ -66,30 +66,30 @@ def bb_pipeline_diff_joint(subject, jobHold, fileConfiguration, queue, coeff,
finalJob="1"
if run_block_2:
jobPREPARE = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + short_queues + ' -N "bb_pre_eddy_' + subject + '" -j ' + str(jobHold) + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_pre_eddy ' + subject )
jobPREPARE = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + short_queues + ' -N "bb_pre_eddy_' + subject + '" -j ' + str(jobHold) + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_pre_eddy ' + subject )
if eddy_cpu:
jobEDDY = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_eddy_cpu_' + subject + '" -j ' + jobPREPARE + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_eddy_wrap_cpu ' + baseDir)
jobEDDY = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_eddy_cpu_' + subject + '" -j ' + jobPREPARE + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_eddy_wrap_cpu ' + baseDir)
else:
jobEDDY = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_eddy_gpu_' + subject + '" -j ' + jobPREPARE + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_eddy_wrap_gpu ' + baseDir)
jobEDDY = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_eddy_gpu_' + subject + '" -j ' + jobPREPARE + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_eddy_wrap_gpu ' + baseDir)
finalJob = finalJob + "," + str(jobEDDY)
if run_block_3:
jobPOSTEDDY = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_post_eddy_' + subject + '" -j ' + jobEDDY + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_post_eddy ' + baseDir + ' ' + coeff + ' ' + str(b_value_shell))
jobDTIFIT = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + short_queues + ' -N "bb_dtifit_' + subject + '" -j ' + jobPOSTEDDY + ' -l ' + logDir + ' ${FSLDIR}/bin/dtifit -k ' + baseDir + '/dMRI/dMRI/data_ud_1_shell -m ' + baseDir + '/dMRI/dMRI/nodif_brain_mask_ud -r ' + baseDir + '/dMRI/dMRI/data_ud_1_shell.bvec -b ' + baseDir + '/dMRI/dMRI/data_ud_1_shell.bval -o ' + baseDir + '/dMRI/dMRI/dti')
jobTBSS = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_tbss_' + subject + '" -j ' + jobDTIFIT + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_tbss/bb_tbss_general ' + subject )
jobPOSTEDDY = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_post_eddy_' + subject + '" -j ' + jobEDDY + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_eddy/bb_post_eddy ' + baseDir + ' ' + coeff + ' ' + str(b_value_shell))
jobDTIFIT = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + short_queues + ' -N "bb_dtifit_' + subject + '" -j ' + jobPOSTEDDY + ' -l ' + logDir + ' ${FSLDIR}/bin/dtifit -k ' + baseDir + '/dMRI/dMRI/data_ud_1_shell -m ' + baseDir + '/dMRI/dMRI/nodif_brain_mask_ud -r ' + baseDir + '/dMRI/dMRI/data_ud_1_shell.bvec -b ' + baseDir + '/dMRI/dMRI/data_ud_1_shell.bval -o ' + baseDir + '/dMRI/dMRI/dti')
jobTBSS = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_tbss_' + subject + '" -j ' + jobDTIFIT + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_tbss/bb_tbss_general ' + subject )
if num_shells > 1:
jobNODDI = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_NODDI_' + subject + '" -j ' + jobTBSS + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_NODDI ' + subject )
jobPREBEDPOSTX = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + short_queues + ' -N "bb_pre_bedpostx_' + subject + '" -j ' + jobDTIFIT + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_bedpostx/bb_pre_bedpostx ' + baseDir + '/dMRI/dMRI')
jobNODDI = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_NODDI_' + subject + '" -j ' + jobTBSS + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_NODDI ' + subject )
jobPREBEDPOSTX = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + short_queues + ' -N "bb_pre_bedpostx_' + subject + '" -j ' + jobDTIFIT + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_bedpostx/bb_pre_bedpostx ' + baseDir + '/dMRI/dMRI')
finalJob = finalJob + "," + str(jobPREBEDPOSTX)
if run_block_4:
if bedpostx_cpu:
jobBEDPOSTX = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_bedpostx_cpu_' + subject + '" -j ' + jobPREBEDPOSTX + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_bedpostx/bb_bedpostx_cpu ' + baseDir + '/dMRI/dMRI')
jobAUTOPTX = LT.runCommand(logger, '${BB_BIN_DIR}/bb_diffusion_pipeline/bb_autoPtx/bb_autoPtx_queue_cpu_joint ' + subject + ' ' + jobBEDPOSTX + ',' + jobTBSS + ' ' + long_queues)
jobBEDPOSTX = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_bedpostx_cpu_' + subject + '" -j ' + jobPREBEDPOSTX + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_bedpostx/bb_bedpostx_cpu ' + baseDir + '/dMRI/dMRI')
jobAUTOPTX = LT.runCommand(logger, '${BB_BIN_DIR}/bb_diffusion_pipeline/bb_autoPtx/bb_autoPtx_queue_cpu_joint ' + subject + ' ' + jobBEDPOSTX + ',' + jobTBSS + ' ' + long_queues)
else:
jobBEDPOSTX = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_bedpostx_gpu_' + subject + '" -j ' + jobPREBEDPOSTX + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_bedpostx/bb_bedpostx_gpu ' + baseDir + '/dMRI/dMRI')
jobAUTOPTX = LT.runCommand(logger, '${BB_BIN_DIR}/bb_diffusion_pipeline/bb_autoPtx/bb_autoPtx_queue_gpu_joint ' + subject + ' ' + jobBEDPOSTX + ',' + jobTBSS + ' ' + long_queues)
jobBEDPOSTX = LT.runCommand(logger, '${FSLDIR}/bin/fsl_sub -q ' + long_queues + ' -N "bb_bedpostx_gpu_' + subject + '" -j ' + jobPREBEDPOSTX + ' -l ' + logDir + ' $BB_BIN_DIR/bb_diffusion_pipeline/bb_bedpostx/bb_bedpostx_gpu ' + baseDir + '/dMRI/dMRI')
jobAUTOPTX = LT.runCommand(logger, '${BB_BIN_DIR}/bb_diffusion_pipeline/bb_autoPtx/bb_autoPtx_queue_gpu_joint ' + subject + ' ' + jobBEDPOSTX + ',' + jobTBSS + ' ' + long_queues)
finalJob = finalJob + "," + str(jobAUTOPTX)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment