Skip to content

Commit

Permalink
fix wf
Browse files Browse the repository at this point in the history
  • Loading branch information
rcannood committed Sep 26, 2024
1 parent 214f782 commit dc39223
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 18 deletions.
4 changes: 2 additions & 2 deletions src/api/comp_data_preprocessor.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@ arguments:
__merge__: file_common_scrnaseq.yaml
direction: input
required: true
- name: "--output_ist"
- name: "--output_sp"
__merge__: file_raw_ist.yaml
direction: output
required: true
- name: "--output_scrnaseq"
- name: "--output_sc"
__merge__: file_scrnaseq_reference.yaml
direction: output
required: true
Expand Down
20 changes: 4 additions & 16 deletions src/workflows/process_datasets/main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -14,31 +14,19 @@ workflow run_wf {
main:
output_ch = input_ch

// example of channel event:
// ["mouse_brain_combined", [
// "input_sc": file("resources_test/common/2023_yao_mouse_brain_scrnaseq_10xv2/dataset.h5ad"),
// "input_sp": file("resources_test/common/2023_10x_mouse_brain_xenium_rep1/dataset.zarr")]]

| process_dataset_comp.run(
fromState: [
input_ist: "input_sp",
input_scrnaseq: "input_sc"
input_sp: "input_sp",
input_sc: "input_sc"
],
toState: [
output_sc: "output_scrnaseq",
output_sp: "output_ist"
output_sc: "output_sc",
output_sp: "output_sp"
]
)

// example of channel event at this point:
// ["my_id", ["input_sc": ..., "input_sp": ...,
// "output_sc": file("..."), "output_sp": file("...")]]

| setState(["output_sp", "output_sc"])

// example of channel event at this point:
// ["my_id", ["output_sc": file("..."), "output_sp": file("...")]]

emit:
output_ch
}
Expand Down

0 comments on commit dc39223

Please sign in to comment.