Data Output¶
Similarly important to data input is data output. Using a data output module allows you to restructure and rename computed output and to spatially differentiate relevant output files from the temporary computed intermediate files in the working directory. Nipype provides the following modules to handle data stream output:
DataSink
JSONFileSink
MySQLSink
SQLiteSink
XNATSink
This tutorial covers only DataSink. For the rest, see the section interfaces.io on the official homepage.
DataSink¶
A workflow working directory is like a cache. It contains not only the outputs of various processing stages, it also contains various extraneous information such as execution reports, hashfiles determining the input state of processes. All of this is embedded in a hierarchical structure that reflects the iterables that have been used in the workflow. This makes navigating the working directory a not so pleasant experience. And typically the user is interested in preserving only a small percentage of these outputs. The DataSink interface can be used to extract components from this cache and store it at a different location. For XNAT-based storage, see XNATSink.
Let’s assume we have the following workflow.
The following code segment defines the DataSink node and sets the base_directory in which all outputs will be stored. The container input creates a subdirectory within the base_directory. If you are iterating a workflow over subjects, it may be useful to save it within a folder with the subject id.
datasink = pe.Node(nio.DataSink(), name='sinker')
datasink.inputs.base_directory = '/path/to/output'
workflow.connect(inputnode, 'subject_id', datasink, 'container')
If we wanted to save the realigned files and the realignment parameters to the same place the most intuitive option would be:
workflow.connect(realigner, 'realigned_files', datasink, 'motion')
workflow.connect(realigner, 'realignment_parameters', datasink, 'motion')
However, this will not work as only one connection is allowed per input port. So we need to create a second port. We can store the files in a separate folder.
workflow.connect(realigner, 'realigned_files', datasink, 'motion')
workflow.connect(realigner, 'realignment_parameters', datasink, 'motion.par')
The period (.) indicates that a subfolder called par should be created. But if we wanted to store it in the same folder as the realigned files, we would use the .@ syntax. The @ tells the DataSink interface to not create the subfolder. This will allow us to create different named input ports for DataSink and allow the user to store the files in the same folder.
workflow.connect(realigner, 'realigned_files', datasink, 'motion')
workflow.connect(realigner, 'realignment_parameters', datasink, 'motion.@par')
The syntax for the input port of DataSink takes the following form:
string[[.[@]]string[[.[@]]string] ...]
where parts between paired [] are optional.
MapNode¶
In order to use DataSink inside a MapNode, its inputs have to be defined inside the constructor using the infields keyword arg.
Parameterization¶
As discussed in Iterables, one can run a workflow iterating over various inputs using the iterables attribute of nodes. This means that a given workflow can have multiple outputs depending on how many iterables are there. Iterables create working directory subfolders such as _iterable_name_value. The parameterization input parameter controls whether the data stored using DataSink is in a folder structure that contains this iterable information or not. It is generally recommended to set this to True when using multiple nested iterables.
Substitutions¶
The substitutions and regexp_substitutions inputs allow users to modify the output destination path and name of a file. Substitutions are a list of 2-tuples and are carried out in the order in which they were entered. Assuming that the output path of a file is:
/root/container/_variable_1/file_subject_realigned.nii
we can use substitutions to clean up the output path.
datasink.inputs.substitutions = [('_variable', 'variable'),
('file_subject_', '')]
This will rewrite the file as:
/root/container/variable_1/realigned.nii
Realistic Example¶
Preparation¶
Before we can use DataSink we first need to run a workflow. For this purpose, let’s create a very short preprocessing workflow that realigns and smooths one functional image of one subject.
First, let’s create a SelectFiles node. For an explanation of this step, see the Data Input tutorial.
from nipype import SelectFiles, Node
# Create SelectFiles node
templates={'func': '{subject}/{session}/func/{subject}_{session}_task-fingerfootlips_bold.nii.gz'}
sf = Node(SelectFiles(templates),
name='selectfiles')
sf.inputs.base_directory = '/data/ds000114'
sf.inputs.subject = 'sub-01'
sf.inputs.session = 'ses-test'
Second, let’s create the motion correction and smoothing node. For an explanation about this step, see the Nodes and Interfaces tutorial.
from nipype.interfaces.fsl import MCFLIRT, IsotropicSmooth
# Create Motion Correction Node
mcflirt = Node(MCFLIRT(mean_vol=True,
save_plots=True),
name='mcflirt')
# Create Smoothing node
smooth = Node(IsotropicSmooth(fwhm=4),
name='smooth')
Third, let’s create the workflow that will contain those three nodes. For an explanation about this step, see the Workflow tutorial.
from nipype import Workflow
from os.path import abspath
# Create a preprocessing workflow
wf = Workflow(name="preprocWF")
wf.base_dir = '/output/working_dir'
# Connect the three nodes to each other
wf.connect([(sf, mcflirt, [("func", "in_file")]),
(mcflirt, smooth, [("out_file", "in_file")])])
Now that everything is set up, let’s run the preprocessing workflow.
wf.run()
211017-17:06:28,711 nipype.workflow INFO:
Workflow preprocWF settings: ['check', 'execution', 'logging', 'monitoring']
211017-17:06:28,720 nipype.workflow INFO:
Running serially.
211017-17:06:28,721 nipype.workflow INFO:
[Node] Setting-up "preprocWF.selectfiles" in "/output/working_dir/preprocWF/selectfiles".
211017-17:06:28,726 nipype.workflow INFO:
[Node] Running "selectfiles" ("nipype.interfaces.io.SelectFiles")
211017-17:06:28,736 nipype.workflow INFO:
[Node] Finished "preprocWF.selectfiles".
211017-17:06:28,738 nipype.workflow INFO:
[Node] Setting-up "preprocWF.mcflirt" in "/output/working_dir/preprocWF/mcflirt".
211017-17:06:28,747 nipype.workflow INFO:
[Node] Running "mcflirt" ("nipype.interfaces.fsl.preprocess.MCFLIRT"), a CommandLine Interface with command:
mcflirt -in /data/ds000114/sub-01/ses-test/func/sub-01_ses-test_task-fingerfootlips_bold.nii.gz -meanvol -out /output/working_dir/preprocWF/mcflirt/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz -plots
211017-17:07:39,568 nipype.workflow INFO:
[Node] Finished "preprocWF.mcflirt".
211017-17:07:39,571 nipype.workflow INFO:
[Node] Setting-up "preprocWF.smooth" in "/output/working_dir/preprocWF/smooth".
211017-17:07:39,583 nipype.workflow INFO:
[Node] Running "smooth" ("nipype.interfaces.fsl.maths.IsotropicSmooth"), a CommandLine Interface with command:
fslmaths /output/working_dir/preprocWF/mcflirt/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz -s 1.69864 /output/working_dir/preprocWF/smooth/sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
211017-17:07:51,189 nipype.workflow INFO:
[Node] Finished "preprocWF.smooth".
<networkx.classes.digraph.DiGraph at 0x7f6f6efd7b90>
After the execution of the workflow we have all the data hidden in the working directory 'working_dir'. Let’s take a closer look at the content of this folder:
! tree /output/working_dir/preprocWF
/output/working_dir/preprocWF
├── d3.js
├── graph1.json
├── graph.json
├── index.html
├── mcflirt
│ ├── _0xa5c4a814d227c6af76bc7488d169dc1a.json
│ ├── command.txt
│ ├── _inputs.pklz
│ ├── _node.pklz
│ ├── _report
│ │ └── report.rst
│ ├── result_mcflirt.pklz
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz
├── selectfiles
│ ├── _0x8be4cb43842af73f06e36ceafabda572.json
│ ├── _inputs.pklz
│ ├── _node.pklz
│ ├── _report
│ │ └── report.rst
│ └── result_selectfiles.pklz
└── smooth
├── _0x2745cf755ee377f13be5b3edde9dc7fc.json
├── command.txt
├── _inputs.pklz
├── _node.pklz
├── _report
│ └── report.rst
├── result_smooth.pklz
└── sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
6 directories, 23 files
As we can see, there is way too much content that we might not really care about. To relocate and rename all the files that are relevant to you, you can use DataSink.
How to use DataSink¶
DataSink is Nipype’s standard output module to restructure your output files. It allows you to relocate and rename files that you deem relevant.
Based on the preprocessing pipeline above, let’s say we want to keep the smoothed functional images as well as the motion correction parameters. To do this, we first need to create the DataSink object.
from nipype.interfaces.io import DataSink
# Create DataSink object
sinker = Node(DataSink(), name='sinker')
# Name of the output folder
sinker.inputs.base_directory = '/output/working_dir/preprocWF_output'
# Connect DataSink with the relevant nodes
wf.connect([(smooth, sinker, [('out_file', 'in_file')]),
(mcflirt, sinker, [('mean_img', 'mean_img'),
('par_file', 'par_file')]),
])
wf.run()
211017-17:07:51,984 nipype.workflow INFO:
Workflow preprocWF settings: ['check', 'execution', 'logging', 'monitoring']
211017-17:07:52,8 nipype.workflow INFO:
Running serially.
211017-17:07:52,9 nipype.workflow INFO:
[Node] Setting-up "preprocWF.selectfiles" in "/output/working_dir/preprocWF/selectfiles".
211017-17:07:52,18 nipype.workflow INFO:
[Node] Running "selectfiles" ("nipype.interfaces.io.SelectFiles")
211017-17:07:52,27 nipype.workflow INFO:
[Node] Finished "preprocWF.selectfiles".
211017-17:07:52,28 nipype.workflow INFO:
[Node] Setting-up "preprocWF.mcflirt" in "/output/working_dir/preprocWF/mcflirt".
211017-17:07:52,33 nipype.workflow INFO:
[Node] Outdated cache found for "preprocWF.mcflirt".
211017-17:07:52,41 nipype.workflow INFO:
[Node] Running "mcflirt" ("nipype.interfaces.fsl.preprocess.MCFLIRT"), a CommandLine Interface with command:
mcflirt -in /data/ds000114/sub-01/ses-test/func/sub-01_ses-test_task-fingerfootlips_bold.nii.gz -meanvol -out /output/working_dir/preprocWF/mcflirt/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz -plots
211017-17:09:02,448 nipype.workflow INFO:
[Node] Finished "preprocWF.mcflirt".
211017-17:09:02,451 nipype.workflow INFO:
[Node] Setting-up "preprocWF.smooth" in "/output/working_dir/preprocWF/smooth".
211017-17:09:02,455 nipype.workflow INFO:
[Node] Outdated cache found for "preprocWF.smooth".
211017-17:09:02,466 nipype.workflow INFO:
[Node] Running "smooth" ("nipype.interfaces.fsl.maths.IsotropicSmooth"), a CommandLine Interface with command:
fslmaths /output/working_dir/preprocWF/mcflirt/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz -s 1.69864 /output/working_dir/preprocWF/smooth/sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
211017-17:09:12,962 nipype.workflow INFO:
[Node] Finished "preprocWF.smooth".
211017-17:09:12,966 nipype.workflow INFO:
[Node] Setting-up "preprocWF.sinker" in "/output/working_dir/preprocWF/sinker".
211017-17:09:12,978 nipype.workflow INFO:
[Node] Running "sinker" ("nipype.interfaces.io.DataSink")
211017-17:09:12,987 nipype.workflow INFO:
[Node] Finished "preprocWF.sinker".
<networkx.classes.digraph.DiGraph at 0x7f6f6efd79d0>
Let’s take a look at the output folder:
! tree /output/working_dir/preprocWF_output
/output/working_dir/preprocWF_output
├── in_file
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
├── mean_img
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz
└── par_file
└── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par
3 directories, 3 files
This looks nice. It is what we asked it to do. But having a specific output folder for each individual output file might be suboptimal. So let’s change the code above to save the output in one folder, which we will call 'preproc'.
For this we can use the same code as above. We only have to change the connection part:
wf.connect([(smooth, sinker, [('out_file', 'preproc.@in_file')]),
(mcflirt, sinker, [('mean_img', 'preproc.@mean_img'),
('par_file', 'preproc.@par_file')]),
])
wf.run()
211017-17:09:13,789 nipype.workflow INFO:
Workflow preprocWF settings: ['check', 'execution', 'logging', 'monitoring']
211017-17:09:13,811 nipype.workflow INFO:
Running serially.
211017-17:09:13,812 nipype.workflow INFO:
[Node] Setting-up "preprocWF.selectfiles" in "/output/working_dir/preprocWF/selectfiles".
211017-17:09:13,821 nipype.workflow INFO:
[Node] Running "selectfiles" ("nipype.interfaces.io.SelectFiles")
211017-17:09:13,849 nipype.workflow INFO:
[Node] Finished "preprocWF.selectfiles".
211017-17:09:13,851 nipype.workflow INFO:
[Node] Setting-up "preprocWF.mcflirt" in "/output/working_dir/preprocWF/mcflirt".
211017-17:09:13,857 nipype.workflow INFO:
[Node] Cached "preprocWF.mcflirt" - collecting precomputed outputs
211017-17:09:13,857 nipype.workflow INFO:
[Node] "preprocWF.mcflirt" found cached.
211017-17:09:13,859 nipype.workflow INFO:
[Node] Setting-up "preprocWF.smooth" in "/output/working_dir/preprocWF/smooth".
211017-17:09:13,866 nipype.workflow INFO:
[Node] Cached "preprocWF.smooth" - collecting precomputed outputs
211017-17:09:13,867 nipype.workflow INFO:
[Node] "preprocWF.smooth" found cached.
211017-17:09:13,869 nipype.workflow INFO:
[Node] Setting-up "preprocWF.sinker" in "/output/working_dir/preprocWF/sinker".
211017-17:09:13,878 nipype.workflow INFO:
[Node] Outdated cache found for "preprocWF.sinker".
211017-17:09:13,883 nipype.workflow INFO:
[Node] Running "sinker" ("nipype.interfaces.io.DataSink")
211017-17:09:13,893 nipype.workflow INFO:
[Node] Finished "preprocWF.sinker".
<networkx.classes.digraph.DiGraph at 0x7f6f6acc31d0>
Let’s take a look at the new output folder structure:
! tree /output/working_dir/preprocWF_output
/output/working_dir/preprocWF_output
├── in_file
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
├── mean_img
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz
├── par_file
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par
└── preproc
├── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz
├── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par
└── sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
4 directories, 6 files
This is already much better. But what if you want to rename the output files to represent something a bit more readable. For this DataSink has the substitution input field.
For example, let’s assume we want to get rid of the string 'task-fingerfootlips' and 'bold_mcf' and that we want to rename the mean file, as well as adapt the file ending of the motion parameter file:
# Define substitution strings
substitutions = [('_task-fingerfootlips', ''),
("_ses-test", ""),
('_bold_mcf', ''),
('.nii.gz_mean_reg', '_mean'),
('.nii.gz.par', '.par')]
# Feed the substitution strings to the DataSink node
sinker.inputs.substitutions = substitutions
# Run the workflow again with the substitutions in place
wf.run()
211017-17:09:14,534 nipype.workflow INFO:
Workflow preprocWF settings: ['check', 'execution', 'logging', 'monitoring']
211017-17:09:14,545 nipype.workflow INFO:
Running serially.
211017-17:09:14,547 nipype.workflow INFO:
[Node] Setting-up "preprocWF.selectfiles" in "/output/working_dir/preprocWF/selectfiles".
211017-17:09:14,557 nipype.workflow INFO:
[Node] Running "selectfiles" ("nipype.interfaces.io.SelectFiles")
211017-17:09:14,564 nipype.workflow INFO:
[Node] Finished "preprocWF.selectfiles".
211017-17:09:14,566 nipype.workflow INFO:
[Node] Setting-up "preprocWF.mcflirt" in "/output/working_dir/preprocWF/mcflirt".
211017-17:09:14,576 nipype.workflow INFO:
[Node] Cached "preprocWF.mcflirt" - collecting precomputed outputs
211017-17:09:14,577 nipype.workflow INFO:
[Node] "preprocWF.mcflirt" found cached.
211017-17:09:14,578 nipype.workflow INFO:
[Node] Setting-up "preprocWF.smooth" in "/output/working_dir/preprocWF/smooth".
211017-17:09:14,588 nipype.workflow INFO:
[Node] Cached "preprocWF.smooth" - collecting precomputed outputs
211017-17:09:14,590 nipype.workflow INFO:
[Node] "preprocWF.smooth" found cached.
211017-17:09:14,592 nipype.workflow INFO:
[Node] Setting-up "preprocWF.sinker" in "/output/working_dir/preprocWF/sinker".
211017-17:09:14,607 nipype.workflow INFO:
[Node] Outdated cache found for "preprocWF.sinker".
211017-17:09:14,613 nipype.workflow INFO:
[Node] Running "sinker" ("nipype.interfaces.io.DataSink")
211017-17:09:14,615 nipype.interface INFO:
sub: /output/working_dir/preprocWF_output/in_file/sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz -> /output/working_dir/preprocWF_output/in_file/sub-01_smooth.nii.gz
211017-17:09:14,617 nipype.interface INFO:
sub: /output/working_dir/preprocWF_output/preproc/sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz -> /output/working_dir/preprocWF_output/preproc/sub-01_smooth.nii.gz
211017-17:09:14,620 nipype.interface INFO:
sub: /output/working_dir/preprocWF_output/mean_img/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz -> /output/working_dir/preprocWF_output/mean_img/sub-01_mean.nii.gz
211017-17:09:14,623 nipype.interface INFO:
sub: /output/working_dir/preprocWF_output/par_file/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par -> /output/working_dir/preprocWF_output/par_file/sub-01.par
211017-17:09:14,625 nipype.interface INFO:
sub: /output/working_dir/preprocWF_output/preproc/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz -> /output/working_dir/preprocWF_output/preproc/sub-01_mean.nii.gz
211017-17:09:14,628 nipype.interface INFO:
sub: /output/working_dir/preprocWF_output/preproc/sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par -> /output/working_dir/preprocWF_output/preproc/sub-01.par
211017-17:09:14,635 nipype.workflow INFO:
[Node] Finished "preprocWF.sinker".
<networkx.classes.digraph.DiGraph at 0x7f6f6acd76d0>
Now, let’s take a final look at the output folder:
! tree /output/working_dir/preprocWF_output
/output/working_dir/preprocWF_output
├── in_file
│ ├── sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
│ └── sub-01_smooth.nii.gz
├── mean_img
│ ├── sub-01_mean.nii.gz
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz
├── par_file
│ ├── sub-01.par
│ └── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par
└── preproc
├── sub-01_mean.nii.gz
├── sub-01.par
├── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz_mean_reg.nii.gz
├── sub-01_ses-test_task-fingerfootlips_bold_mcf.nii.gz.par
├── sub-01_ses-test_task-fingerfootlips_bold_mcf_smooth.nii.gz
└── sub-01_smooth.nii.gz
4 directories, 12 files
Cool, much clearer filenames!
Exercise 1¶
Create a simple workflow for skullstriping with FSL, the first node should use BET interface and the second node will be a DataSink. Test two methods of connecting the nodes and check the content of the output directory.
# write your solution here
from nipype import Node, Workflow
from nipype.interfaces.io import DataSink
from nipype.interfaces.fsl import BET
# Skullstrip process
ex1_skullstrip = Node(BET(mask=True), name="ex1_skullstrip")
ex1_skullstrip.inputs.in_file = "/data/ds000114/sub-01/ses-test/anat/sub-01_ses-test_T1w.nii.gz"
# Create DataSink node
ex1_sinker = Node(DataSink(), name='ex1_sinker')
ex1_sinker.inputs.base_directory = '/output/working_dir/ex1_output'
# and a workflow
ex1_wf = Workflow(name="ex1", base_dir = '/output/working_dir')
# let's try the first method of connecting the BET node to the DataSink node
ex1_wf.connect([(ex1_skullstrip, ex1_sinker, [('mask_file', 'mask_file'),
('out_file', 'out_file')]),
])
ex1_wf.run()
211017-17:09:15,331 nipype.workflow INFO:
Workflow ex1 settings: ['check', 'execution', 'logging', 'monitoring']
211017-17:09:15,342 nipype.workflow INFO:
Running serially.
211017-17:09:15,343 nipype.workflow INFO:
[Node] Setting-up "ex1.ex1_skullstrip" in "/output/working_dir/ex1/ex1_skullstrip".
211017-17:09:15,357 nipype.workflow INFO:
[Node] Running "ex1_skullstrip" ("nipype.interfaces.fsl.preprocess.BET"), a CommandLine Interface with command:
bet /data/ds000114/sub-01/ses-test/anat/sub-01_ses-test_T1w.nii.gz /output/working_dir/ex1/ex1_skullstrip/sub-01_ses-test_T1w_brain.nii.gz -m
211017-17:09:19,474 nipype.workflow INFO:
[Node] Finished "ex1.ex1_skullstrip".
211017-17:09:19,476 nipype.workflow INFO:
[Node] Setting-up "ex1.ex1_sinker" in "/output/working_dir/ex1/ex1_sinker".
211017-17:09:19,484 nipype.workflow INFO:
[Node] Running "ex1_sinker" ("nipype.interfaces.io.DataSink")
211017-17:09:19,490 nipype.workflow INFO:
[Node] Finished "ex1.ex1_sinker".
<networkx.classes.digraph.DiGraph at 0x7f6f6ee9c2d0>
# and we can check our sinker directory
! tree /output/working_dir/ex1_output
/output/working_dir/ex1_output
├── mask_file
│ └── sub-01_ses-test_T1w_brain_mask.nii.gz
└── out_file
└── sub-01_ses-test_T1w_brain.nii.gz
2 directories, 2 files
# now we can try the other method of connecting the node to DataSink
ex1_wf.connect([(ex1_skullstrip, ex1_sinker, [('mask_file', 'bet.@mask_file'),
('out_file', 'bet.@out_file')]),
])
ex1_wf.run()
211017-17:09:20,132 nipype.workflow INFO:
Workflow ex1 settings: ['check', 'execution', 'logging', 'monitoring']
211017-17:09:20,146 nipype.workflow INFO:
Running serially.
211017-17:09:20,147 nipype.workflow INFO:
[Node] Setting-up "ex1.ex1_skullstrip" in "/output/working_dir/ex1/ex1_skullstrip".
211017-17:09:20,153 nipype.workflow INFO:
[Node] Cached "ex1.ex1_skullstrip" - collecting precomputed outputs
211017-17:09:20,154 nipype.workflow INFO:
[Node] "ex1.ex1_skullstrip" found cached.
211017-17:09:20,157 nipype.workflow INFO:
[Node] Setting-up "ex1.ex1_sinker" in "/output/working_dir/ex1/ex1_sinker".
211017-17:09:20,161 nipype.workflow INFO:
[Node] Outdated cache found for "ex1.ex1_sinker".
211017-17:09:20,167 nipype.workflow INFO:
[Node] Running "ex1_sinker" ("nipype.interfaces.io.DataSink")
211017-17:09:20,174 nipype.workflow INFO:
[Node] Finished "ex1.ex1_sinker".
<networkx.classes.digraph.DiGraph at 0x7f6f6b34d610>
# and check the content of the output directory (you should see a new `bet` subdirectory with both files)
! tree /output/working_dir/ex1_output
/output/working_dir/ex1_output
├── bet
│ ├── sub-01_ses-test_T1w_brain_mask.nii.gz
│ └── sub-01_ses-test_T1w_brain.nii.gz
├── mask_file
│ └── sub-01_ses-test_T1w_brain_mask.nii.gz
└── out_file
└── sub-01_ses-test_T1w_brain.nii.gz
3 directories, 4 files