mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2024-12-26 13:29:12 -05:00
Improve Actions status aggregations (#32860)
Make the result the same as GitHub: * all skipped, then result is skipped * any cancelled, then result cancelled (cherry picked from commit 22c4599542ee3e10bcab4c9136467bbac8e90ba0)
This commit is contained in:
parent
90b65da7e4
commit
1e7b2cb6c9
2 changed files with 31 additions and 9 deletions
|
@ -153,20 +153,25 @@ func UpdateRunJob(ctx context.Context, job *ActionRunJob, cond builder.Cond, col
|
||||||
}
|
}
|
||||||
|
|
||||||
func AggregateJobStatus(jobs []*ActionRunJob) Status {
|
func AggregateJobStatus(jobs []*ActionRunJob) Status {
|
||||||
allSuccessOrSkipped := true
|
allSuccessOrSkipped := len(jobs) != 0
|
||||||
var hasFailure, hasCancelled, hasSkipped, hasWaiting, hasRunning, hasBlocked bool
|
allSkipped := len(jobs) != 0
|
||||||
|
var hasFailure, hasCancelled, hasWaiting, hasRunning, hasBlocked bool
|
||||||
for _, job := range jobs {
|
for _, job := range jobs {
|
||||||
allSuccessOrSkipped = allSuccessOrSkipped && (job.Status == StatusSuccess || job.Status == StatusSkipped)
|
allSuccessOrSkipped = allSuccessOrSkipped && (job.Status == StatusSuccess || job.Status == StatusSkipped)
|
||||||
|
allSkipped = allSkipped && job.Status == StatusSkipped
|
||||||
hasFailure = hasFailure || job.Status == StatusFailure
|
hasFailure = hasFailure || job.Status == StatusFailure
|
||||||
hasCancelled = hasCancelled || job.Status == StatusCancelled
|
hasCancelled = hasCancelled || job.Status == StatusCancelled
|
||||||
hasSkipped = hasSkipped || job.Status == StatusSkipped
|
|
||||||
hasWaiting = hasWaiting || job.Status == StatusWaiting
|
hasWaiting = hasWaiting || job.Status == StatusWaiting
|
||||||
hasRunning = hasRunning || job.Status == StatusRunning
|
hasRunning = hasRunning || job.Status == StatusRunning
|
||||||
hasBlocked = hasBlocked || job.Status == StatusBlocked
|
hasBlocked = hasBlocked || job.Status == StatusBlocked
|
||||||
}
|
}
|
||||||
switch {
|
switch {
|
||||||
|
case allSkipped:
|
||||||
|
return StatusSkipped
|
||||||
case allSuccessOrSkipped:
|
case allSuccessOrSkipped:
|
||||||
return StatusSuccess
|
return StatusSuccess
|
||||||
|
case hasCancelled:
|
||||||
|
return StatusCancelled
|
||||||
case hasFailure:
|
case hasFailure:
|
||||||
return StatusFailure
|
return StatusFailure
|
||||||
case hasRunning:
|
case hasRunning:
|
||||||
|
@ -175,10 +180,6 @@ func AggregateJobStatus(jobs []*ActionRunJob) Status {
|
||||||
return StatusWaiting
|
return StatusWaiting
|
||||||
case hasBlocked:
|
case hasBlocked:
|
||||||
return StatusBlocked
|
return StatusBlocked
|
||||||
case hasCancelled:
|
|
||||||
return StatusCancelled
|
|
||||||
case hasSkipped:
|
|
||||||
return StatusSkipped
|
|
||||||
default:
|
default:
|
||||||
return StatusUnknown // it shouldn't happen
|
return StatusUnknown // it shouldn't happen
|
||||||
}
|
}
|
||||||
|
|
|
@ -11,6 +11,7 @@ import (
|
||||||
|
|
||||||
func TestAggregateJobStatus(t *testing.T) {
|
func TestAggregateJobStatus(t *testing.T) {
|
||||||
testStatuses := func(expected Status, statuses []Status) {
|
testStatuses := func(expected Status, statuses []Status) {
|
||||||
|
t.Helper()
|
||||||
var jobs []*ActionRunJob
|
var jobs []*ActionRunJob
|
||||||
for _, v := range statuses {
|
for _, v := range statuses {
|
||||||
jobs = append(jobs, &ActionRunJob{Status: v})
|
jobs = append(jobs, &ActionRunJob{Status: v})
|
||||||
|
@ -29,6 +30,16 @@ func TestAggregateJobStatus(t *testing.T) {
|
||||||
statuses []Status
|
statuses []Status
|
||||||
expected Status
|
expected Status
|
||||||
}{
|
}{
|
||||||
|
// unknown cases, maybe it shouldn't happen in real world
|
||||||
|
{[]Status{}, StatusUnknown},
|
||||||
|
{[]Status{StatusUnknown, StatusSuccess}, StatusUnknown},
|
||||||
|
{[]Status{StatusUnknown, StatusSkipped}, StatusUnknown},
|
||||||
|
{[]Status{StatusUnknown, StatusFailure}, StatusFailure},
|
||||||
|
{[]Status{StatusUnknown, StatusCancelled}, StatusCancelled},
|
||||||
|
{[]Status{StatusUnknown, StatusWaiting}, StatusWaiting},
|
||||||
|
{[]Status{StatusUnknown, StatusRunning}, StatusRunning},
|
||||||
|
{[]Status{StatusUnknown, StatusBlocked}, StatusBlocked},
|
||||||
|
|
||||||
// success with other status
|
// success with other status
|
||||||
{[]Status{StatusSuccess}, StatusSuccess},
|
{[]Status{StatusSuccess}, StatusSuccess},
|
||||||
{[]Status{StatusSuccess, StatusSkipped}, StatusSuccess}, // skipped doesn't affect success
|
{[]Status{StatusSuccess, StatusSkipped}, StatusSuccess}, // skipped doesn't affect success
|
||||||
|
@ -38,18 +49,28 @@ func TestAggregateJobStatus(t *testing.T) {
|
||||||
{[]Status{StatusSuccess, StatusRunning}, StatusRunning},
|
{[]Status{StatusSuccess, StatusRunning}, StatusRunning},
|
||||||
{[]Status{StatusSuccess, StatusBlocked}, StatusBlocked},
|
{[]Status{StatusSuccess, StatusBlocked}, StatusBlocked},
|
||||||
|
|
||||||
|
// any cancelled, then cancelled
|
||||||
|
{[]Status{StatusCancelled}, StatusCancelled},
|
||||||
|
{[]Status{StatusCancelled, StatusSuccess}, StatusCancelled},
|
||||||
|
{[]Status{StatusCancelled, StatusSkipped}, StatusCancelled},
|
||||||
|
{[]Status{StatusCancelled, StatusFailure}, StatusCancelled},
|
||||||
|
{[]Status{StatusCancelled, StatusWaiting}, StatusCancelled},
|
||||||
|
{[]Status{StatusCancelled, StatusRunning}, StatusCancelled},
|
||||||
|
{[]Status{StatusCancelled, StatusBlocked}, StatusCancelled},
|
||||||
|
|
||||||
// failure with other status, fail fast
|
// failure with other status, fail fast
|
||||||
// Should "running" win? Maybe no: old code does make "running" win, but GitHub does fail fast.
|
// Should "running" win? Maybe no: old code does make "running" win, but GitHub does fail fast.
|
||||||
{[]Status{StatusFailure}, StatusFailure},
|
{[]Status{StatusFailure}, StatusFailure},
|
||||||
{[]Status{StatusFailure, StatusSuccess}, StatusFailure},
|
{[]Status{StatusFailure, StatusSuccess}, StatusFailure},
|
||||||
{[]Status{StatusFailure, StatusSkipped}, StatusFailure},
|
{[]Status{StatusFailure, StatusSkipped}, StatusFailure},
|
||||||
{[]Status{StatusFailure, StatusCancelled}, StatusFailure},
|
{[]Status{StatusFailure, StatusCancelled}, StatusCancelled},
|
||||||
{[]Status{StatusFailure, StatusWaiting}, StatusFailure},
|
{[]Status{StatusFailure, StatusWaiting}, StatusFailure},
|
||||||
{[]Status{StatusFailure, StatusRunning}, StatusFailure},
|
{[]Status{StatusFailure, StatusRunning}, StatusFailure},
|
||||||
{[]Status{StatusFailure, StatusBlocked}, StatusFailure},
|
{[]Status{StatusFailure, StatusBlocked}, StatusFailure},
|
||||||
|
|
||||||
// skipped with other status
|
// skipped with other status
|
||||||
{[]Status{StatusSkipped}, StatusSuccess},
|
// TODO: need to clarify whether a PR with "skipped" job status is considered as "mergeable" or not.
|
||||||
|
{[]Status{StatusSkipped}, StatusSkipped},
|
||||||
{[]Status{StatusSkipped, StatusSuccess}, StatusSuccess},
|
{[]Status{StatusSkipped, StatusSuccess}, StatusSuccess},
|
||||||
{[]Status{StatusSkipped, StatusFailure}, StatusFailure},
|
{[]Status{StatusSkipped, StatusFailure}, StatusFailure},
|
||||||
{[]Status{StatusSkipped, StatusCancelled}, StatusCancelled},
|
{[]Status{StatusSkipped, StatusCancelled}, StatusCancelled},
|
||||||
|
|
Loading…
Reference in a new issue