Remove as much as possible from state management code

src/workflows/demo_pipeline/main.nf

@@ -10,39 +10,28 @@ workflow run_wf {
 
         // Turn the Channel event with list of files
         // into multiple Channel events with one file.
-        | expand.run(
-            fromState: { id, state -> state },
-            toState: {id, result, state -> 
-              _mergeMap(state, [ expanded: result.output ])
-            }
-          )
+        | expand
 
         // Remove comments from each TSV input file
         | remove_comments.run(
-            fromState: { id, state -> [ input: state.expanded ] },
-            toState: { id, result, state -> 
-              _mergeMap(state, [ remove_comments: result.output ] ) }
+            fromState: [ input: "output" ],
           )
 
         // Extract single column from each TSV
         | take_column.run(
-            fromState: { id, state -> [ input: state.remove_comments ] },
-            toState: {id, result, state ->
-              _mergeMap(state, [ take_column: result.output ])
-            }
+            fromState: [ input: "output" ],
           )
 
         // Custom toSortedList
-        | vsh_toList.run (
-            fromState: { id, state -> [ id: "run", input: state.take_column ] },
-            toState: { id, result, state -> result }
+        | vsh_toList.run(
+            args: [ id: "run" ],
+            fromState: [ input: "output" ],
           )
 
         // Concatenate TSVs into one
         | combine_columns.run(
             auto: [ publish: true ],
-            fromState: { id, state -> [ input: state.output ] },
-            toState: { id, result, state -> result }
+            fromState: [ input: "output" ],
           )
 
         // View channel contents