Add test

src/test/resources/testnextflowvdsl3/src/test_wfs/invalid_fromstate_argument/config.vsh.yaml

@@ -0,0 +1,12 @@
+name: invalid_fromstate_argument
+namespace: test_wfs
+resources:
+  - type: nextflow_script
+    path: main.nf
+    entrypoint: base
+  # TODO: make absolute when the ns build uses the right CWD
+  - path: ../../../resources
+dependencies:
+  - name: sub_workflow
+platforms:
+  - type: nextflow

src/test/resources/testnextflowvdsl3/src/test_wfs/invalid_fromstate_argument/main.nf

@@ -0,0 +1,33 @@
+workflow base {
+  take: input_ch
+  main:
+
+  // generate list from 0 to 1000
+  ch = Channel.fromList(0..1000)
+    | map { num ->
+      // create temporary file
+      def file = tempFile()
+      file.write("num: $num")
+
+      ["num$num", [ file: file ], ["num": num]]
+    }
+    | sub_workflow.run(
+      fromState: [
+        "file": "file",
+        "thisargumentdoesnotexist": "file", // this should raise
+      ],
+      toState: {id, output, state -> 
+        def newState = [
+          "step1_output": output.output, 
+          "num": state.num,
+          "file": state.file,
+          "thisargumentdoesnotexist": "foo" 
+        ]
+        return newState
+      }
+    )
+
+
+  emit:
+  input_ch
+}

src/test/scala/io/viash/runners/nextflow/NextflowScriptTest.scala

@@ -201,6 +201,20 @@ class NextflowScriptTest extends AnyFunSuite with BeforeAndAfterAll {
   } 
 
 
+  test("Test invalid argument in fromState map", DockerTest, NextflowTest) {
+    val (exitCode, stdOut, stdErr) = NextflowTestHelper.run(
+      mainScript = "target/nextflow/test_wfs/invalid_fromstate_argument/main.nf",
+      args = List(
+        "--publish_dir", "output"
+      ),
+      cwd = tempFolFile
+    )
+
+    assert(exitCode == 1, s"\nexit code was $exitCode\nStd output:\n$stdOut\nStd error:\n$stdErr")
+    assert(stdOut.contains("Error processing fromState for 'sub_workflow': invalid argument 'thisargumentdoesnotexist'"))
+  } 
+
+
   test("Run multiple output channels standalone", NextflowTest) {
     val (exitCode, stdOut, stdErr) = NextflowTestHelper.run(
       mainScript = "target/nextflow/multiple_emit_channels/main.nf",