NXF: Automatically flatten single-file outputs

viash-io · Aug 16, 2021 · c7a3925 · c7a3925
1 parent 6d5655c
commit c7a3925
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/main/scala/com/dataintuitive/viash/platforms/NextFlowPlatform.scala b/src/main/scala/com/dataintuitive/viash/platforms/NextFlowPlatform.scala
@@ -496,8 +496,12 @@ case class NextFlowPlatform(
           |      : it[1].collect{ k, el -> [ it[0], el, it[2] ] }
           |  }""".stripMargin
       } else {
-        """  emit:
-          |  result_""".stripMargin
+        s"""  emit:
+           |  result_.flatMap{ it ->
+           |    (it[1].keySet().size() > 1)
+           |      ? it
+           |      : it[1].collect{ k, el -> [ it[0], el, it[2] ] }
+           |  }""".stripMargin
       }
 
     val setup_main_workflow =