Fix workflow onComplete and onError in the entry workflow

modules/nextflow/src/main/groovy/nextflow/script/WorkflowMetadata.groovy

@@ -303,7 +303,10 @@ class WorkflowMetadata {
      * @param action The action handler
      */
     void onComplete( Closure action ) {
+        onCompleteActions.add(action)
+    }
 
+    void setOnCompleteFormConfig( Closure action ) {
         final clone = (Closure)action.clone()
         clone.delegate = NF.binding.variables
         clone.resolveStrategy = Closure.DELEGATE_FIRST
@@ -335,7 +338,10 @@ class WorkflowMetadata {
      * @param action
      */
     void onError( Closure action ) {
+        onErrorActions.add(action)
+    }
 
+    void setOnErrorFromConfig(Closure action ) {
         final clone = (Closure)action.clone()
         clone.delegate = NF.binding.variables
         clone.resolveStrategy = Closure.DELEGATE_FIRST
@@ -376,11 +382,11 @@ class WorkflowMetadata {
         if( !workflowConfig ) return
         // -- register `onComplete`
         if( workflowConfig.onComplete instanceof Closure ) {
-            onComplete( (Closure)workflowConfig.onComplete )
+            setOnCompleteFormConfig( (Closure)workflowConfig.onComplete )
         }
         // -- register `onError`
         if( workflowConfig.onError instanceof Closure ) {
-            onError( (Closure)workflowConfig.onError )
+            setOnErrorFromConfig( (Closure)workflowConfig.onError )
         }
     }
 

modules/nextflow/src/test/groovy/nextflow/script/WorkflowMetadataTest.groovy

@@ -166,7 +166,7 @@ class WorkflowMetadataTest extends Specification {
         }
 
         when:
-        metadata.onComplete(handler)
+        metadata.setOnCompleteFormConfig(handler)
         metadata.invokeOnComplete()
 
         then:
@@ -190,7 +190,7 @@ class WorkflowMetadataTest extends Specification {
         def metadata = new WorkflowMetadata(session, null)
 
         when:
-        metadata.onComplete {
+        metadata.setOnCompleteFormConfig {
             throw new WorkflowScriptErrorException('You failed!')
         }
         metadata.invokeOnComplete()
@@ -236,7 +236,7 @@ class WorkflowMetadataTest extends Specification {
         }
 
         when:
-        metadata.onError(handler)
+        metadata.setOnErrorFromConfig(handler)
         metadata.invokeOnError(Mock(TraceRecord))
 
         then:

tests/checks/script-vars-oncomplete.nf/.checks

@@ -0,0 +1,21 @@
+set -e
+
+#
+# run normal mode
+#
+echo ''
+$NXF_RUN | tee stdout
+
+[[ `grep -c 'Workflow Executed!' stdout` == 1 ]] || false
+[[ `grep -c 'local variable: local' stdout` == 1 ]] || false
+[[ `grep -c 'param output dir: results' stdout` == 1 ]] || false
+[[ `grep -c 'Method executed!' stdout` == 1 ]] || false
+[[ `grep -c 'script-vars-oncomplete.nf' stdout` == 1 ]] || false
+[[ `grep -c "Can't access to a global variable" stdout` == 1 ]] || false
+[[ `grep -c "Can't access to a private workflow property" stdout` == 1 ]] || false
+[[ `grep -c 'Success!' stdout` == 1 ]] || false
+
+
+
+
+

tests/checks/script-vars-onerror.nf/.checks

@@ -0,0 +1,21 @@
+set -e
+
+#
+# run normal mode
+#
+echo ''
+$NXF_RUN | tee stdout
+
+[[ `grep -c 'Workflow Failed!' stdout` == 1 ]] || false
+[[ `grep -c 'local variable: local' stdout` == 1 ]] || false
+[[ `grep -c 'param output dir: results' stdout` == 1 ]] || false
+[[ `grep -c 'Method executed!' stdout` == 1 ]] || false
+[[ `grep 'Executed script' stdout | grep -c 'script-vars-onerror.nf'` == 1 ]] || false
+[[ `grep -c "Can't access to a global variable" stdout` == 1 ]] || false
+[[ `grep -c "Can't access to a private workflow property" stdout` == 1 ]] || false
+[[ `grep -c 'Failure!' stdout` == 1 ]] || false
+
+
+
+
+

tests/script-vars-oncomplete.nf

@@ -0,0 +1,35 @@
+def global_var = 'global'
+
+def method() {
+    println("Method executed!")
+}
+
+workflow {
+    params.outdir = 'results'
+
+    def local = 'local'
+
+    workflow.onComplete {
+        println("local variable: ${local}")
+        println("param output dir: ${params.outdir}")
+        method() 
+        println("Executed script : ${workflow.scriptFile}")
+        // expected failure
+        try {
+                println("global variable: ${global}")
+        }catch (groovy.lang.MissingPropertyException e){
+                println("Can't access to a global variable")
+        }
+	try {
+                println("workflow private variable: ${events}")
+        }catch (Exception e){
+                println("Can't access to a private workflow property")
+        }
+        if( workflow.success )
+            println("Success!")
+        else
+            println("Failure!")
+    }
+
+    println("Workflow Executed!")
+}

tests/script-vars-onerror.nf

@@ -0,0 +1,35 @@
+def global_var = 'global'
+
+def method() {
+    println("Method executed!")
+}
+
+workflow {
+    params.outdir = 'results'
+
+    def local = 'local'
+
+    workflow.onError {
+        println("local variable: ${local}")
+        println("param output dir: ${params.outdir}")
+        method() 
+        println("Executed script : ${workflow.scriptFile}")
+        // expected failures
+        try {
+                println("global variable: ${global}")
+        }catch (groovy.lang.MissingPropertyException e){
+                println("Can't access to a global variable")
+        }
+	try {
+                println("workflow private variable: ${events}")
+        }catch (Exception e){
+                println("Can't access to a private workflow property")
+        }
+	if( workflow.success )
+            println("Success!")
+        else
+            println("Failure!")
+    }
+
+    throw new Exception("Workflow Failed!")
+}