Skip to content

Commit

Permalink
rename channel
Browse files Browse the repository at this point in the history
  • Loading branch information
rcannood authored Sep 20, 2024
1 parent 754b791 commit 0bd597e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/workflows/run_benchmark/main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ workflow run_wf {
// TODO: can we store everything below in a separate helper function?

// extract the dataset metadata
dataset_meta_ch = dataset_ch
meta_ch = dataset_ch
// only keep one of the normalization methods
| filter{ id, state ->
state.rna_norm == "log_cp10k"
Expand Down Expand Up @@ -204,12 +204,12 @@ workflow run_wf {

// merge all of the output data
output_ch = score_ch
| mix(dataset_meta_ch)
| mix(meta_ch)
| joinStates{ ids, states ->
def mergedStates = states.inject([:]) { acc, m -> acc + m }
[ids[0], mergedStates]
}

emit:
output_ch
}
}

0 comments on commit 0bd597e

Please sign in to comment.