Skip to content

Commit a9c6215

Browse files
committed
Fixed issue with inputs for nested pipeline namespaces
1 parent 767a537 commit a9c6215

File tree

1 file changed

+4
-2
lines changed
  • src/decoding_pipeline/pipelines/data_processing

1 file changed

+4
-2
lines changed

src/decoding_pipeline/pipelines/data_processing/pipeline.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,10 +59,12 @@ def create_pipeline(**kwargs) -> Pipeline:
5959
outputs="center_out_extracted_pkl",
6060
parameters={"params:patient_id": "params:patient_id", "params:gain": "params:gain", "params:bci_states": "params:bci_states"})
6161

62+
# return channel_labelling_pipeline + data_extraction_pipeline
63+
6264
return pipeline(
6365
pipe=channel_labelling_pipeline + data_extraction_pipeline,
6466
namespace="data_preprocessing",
65-
inputs=set(["center_out_hdf5", "selected_channels"]),
66-
outputs={"prefixed_channels": "prefixed_channels", "selected_channels": "selected_channels"},
67+
inputs=set(["center_out_hdf5"]),
68+
outputs={"prefixed_channels": "prefixed_channels", "center_out_extracted_pkl": "center_out_extracted_pkl"},
6769
parameters={"params:patient_id": "params:patient_id", "params:gain": "params:gain", "params:bci_states": "params:bci_states"}
6870
)

0 commit comments

Comments
 (0)