Fix AgentLogObserver printing [SUCCESS] on failed runs

modules/nextflow/src/main/groovy/nextflow/trace/AgentLogObserver.groovy

@@ -220,7 +220,8 @@ class AgentLogObserver implements TraceObserverV2, LogObserver {
         def cached = stats?.cachedCount ?: 0
         def completed = succeeded + failed
 
-        def status = failed > 0 ? 'FAILED' : 'SUCCESS'
+        def hasSessionError = session && !session.isSuccess()
+        def status = (failed > 0 || hasSessionError) ? 'FAILED' : 'SUCCESS'
         printLine("\n[${status}] completed=${completed} failed=${failed} cached=${cached}")
     }
 

modules/nextflow/src/test/groovy/nextflow/trace/AgentLogObserverTest.groovy

@@ -103,8 +103,12 @@ class AgentLogObserverTest extends Specification {
         def statsObserver = Stub(WorkflowStatsObserver) {
             getStats() >> stats
         }
+        def session = Stub(Session) {
+            isSuccess() >> true
+        }
         def observer = new TestAgentLogObserver(output)
         observer.setStatsObserver(statsObserver)
+        observer.onFlowCreate(session)
 
         when:
         observer.onFlowComplete()
@@ -123,8 +127,12 @@ class AgentLogObserverTest extends Specification {
         def statsObserver = Stub(WorkflowStatsObserver) {
             getStats() >> stats
         }
+        def session = Stub(Session) {
+            isSuccess() >> false
+        }
         def observer = new TestAgentLogObserver(output)
         observer.setStatsObserver(statsObserver)
+        observer.onFlowCreate(session)
 
         when:
         observer.onFlowComplete()
@@ -133,6 +141,30 @@ class AgentLogObserverTest extends Specification {
         output[0] == '\n[FAILED] completed=7 failed=2 cached=0'
     }
 
+    def 'should output failed summary when session has error but no task failures'() {
+        given:
+        def output = []
+        def stats = new WorkflowStats()
+        stats.succeededCount = 0
+        stats.failedCount = 0
+        stats.cachedCount = 0
+        def statsObserver = Stub(WorkflowStatsObserver) {
+            getStats() >> stats
+        }
+        def session = Stub(Session) {
+            isSuccess() >> false
+        }
+        def observer = new TestAgentLogObserver(output)
+        observer.setStatsObserver(statsObserver)
+        observer.onFlowCreate(session)
+
+        when:
+        observer.onFlowComplete()
+
+        then:
+        output[0] == '\n[FAILED] completed=0 failed=0 cached=0'
+    }
+
     def 'should handle task complete for failed task'() {
         given:
         def output = []