Skip to content

Commit

Permalink
Run the volume staging workflow in the default base_dir.
Browse files Browse the repository at this point in the history
  • Loading branch information
FredLoney committed Jun 15, 2017
1 parent 14db252 commit 1ae5e22
Showing 1 changed file with 2 additions and 7 deletions.
9 changes: 2 additions & 7 deletions qipipe/pipeline/staging.py
Original file line number Diff line number Diff line change
Expand Up @@ -444,7 +444,7 @@ def _create_workflow(self):


def stage_volume(collection, subject, session, scan, volume, in_files,
dest, base_dir, opts):
dest, opts):
"""
Stages the given volume. The processed DICOM ``.dcm.gz`` files
and merged 3D NIfTI volume ``.nii.gz`` file are placed in the
Expand All @@ -457,7 +457,6 @@ def stage_volume(collection, subject, session, scan, volume, in_files,
:param volume: the volume number
:param in_files: the input DICOM files
:param dest: the parent destination directory
:param base_dir: the parent base directory
:param opts: the non-base_dir :class:`VolumeStagingWorkflow`
initializer options
:return: the volume target directory
Expand All @@ -471,12 +470,8 @@ def stage_volume(collection, subject, session, scan, volume, in_files,
out_dir = "%s/volume%03d" % (dest, volume)
os.mkdir(out_dir)

# The workflow runs in a subdirectory.
vol_base_dir = "%s/volume%03d" % (base_dir, volume)
os.mkdir(vol_base_dir)

# Make the workflow.
stg_wf = VolumeStagingWorkflow(base_dir=base_dir, **opts)
stg_wf = VolumeStagingWorkflow(**opts)
# Execute the workflow.
logger(__name__).debug("Staging %s %s scan %d volume %d in %s..." %
(subject, session, scan, volume, out_dir))
Expand Down

0 comments on commit 1ae5e22

Please sign in to comment.