Skip to content

Commit bb11d2e

Browse files
committed
Fix task progress percentage with failed tasks
Signed-off-by: Ben Sherman <[email protected]>
1 parent a23f684 commit bb11d2e

File tree

3 files changed

+23
-22
lines changed

3 files changed

+23
-22
lines changed

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -475,8 +475,8 @@ class AnsiLogObserver implements TraceObserver {
475475
term.a(Attribute.INTENSITY_FAINT).a(", cached: $stats.cached").reset()
476476
if( stats.stored )
477477
term.a(", stored: $stats.stored")
478-
if( stats.failed )
479-
term.a(", failed: $stats.failed")
478+
if( stats.ignored )
479+
term.a(", ignored: $stats.ignored")
480480
if( stats.retries )
481481
term.a(", retries: $stats.retries")
482482
// Show red cross ('✘') or green tick ('✔') according to status

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

+2-3
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,11 @@ class ProgressRecord implements Cloneable {
6262
}
6363

6464
int getTotalCount() {
65-
pending+ submitted+ running+
66-
succeeded+ failed+ cached+ stored + aborted
65+
pending + submitted + running + succeeded + ignored + cached + stored + aborted
6766
}
6867

6968
int getCompletedCount() {
70-
succeeded+ failed+ cached+ stored
69+
succeeded + ignored + cached + stored
7170
}
7271

7372
@Override

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

+19-17
Original file line numberDiff line numberDiff line change
@@ -53,30 +53,32 @@ class ProgressRecordTest extends Specification {
5353

5454
def 'should get counts' () {
5555
given:
56-
def PENDING =1
57-
def SUBMITTED =2
58-
def RUNNING =3
59-
def SUCCEEDED =4
60-
def FAILED =5
61-
def CACHED =6
62-
def STORED =7
63-
def ABORTED = 8
56+
def PENDING = 1
57+
def SUBMITTED = 2
58+
def RUNNING = 3
59+
def SUCCEEDED = 4
60+
def FAILED = 5
61+
def IGNORED = 6
62+
def CACHED = 7
63+
def STORED = 8
64+
def ABORTED = 9
6465
and:
6566
def rec = new ProgressRecord(10, 'foo')
6667

6768
when:
68-
rec.pending =PENDING
69-
rec.submitted =SUBMITTED
70-
rec.running =RUNNING
71-
rec.succeeded =SUCCEEDED
72-
rec.failed =FAILED
73-
rec.cached =CACHED
74-
rec.stored =STORED
69+
rec.pending = PENDING
70+
rec.submitted = SUBMITTED
71+
rec.running = RUNNING
72+
rec.succeeded = SUCCEEDED
73+
rec.failed = FAILED
74+
rec.ignored = IGNORED
75+
rec.cached = CACHED
76+
rec.stored = STORED
7577
rec.aborted = ABORTED
7678

7779
then:
78-
rec.getCompletedCount() == SUCCEEDED+ FAILED+ CACHED+ STORED
79-
rec.getTotalCount() == PENDING+ SUBMITTED+ RUNNING + SUCCEEDED+ FAILED+ CACHED+ STORED+ ABORTED
80+
rec.getCompletedCount() == SUCCEEDED + IGNORED + CACHED + STORED
81+
rec.getTotalCount() == PENDING + SUBMITTED + RUNNING + SUCCEEDED + IGNORED + CACHED + STORED + ABORTED
8082
}
8183

8284

0 commit comments

Comments
 (0)