mirror of
https://github.com/hanzoai/act.git
synced 2026-10-30 18:48:56 +00:00
zeekayandHanzo Dev
873e28c9b4
The forge needs to PARSE and EVALUATE workflows: model, exprparser, and the two small helper packages they use. It does not need to run them — that is the runner process, and a container runtime is 12000 of the 15754 lines in the upstream act subtree. So this is the 3619 lines that a forge actually calls, not a fork of the whole engine. gitea.com/gitea/runner was the last gitea.com dependency in hanzoai/git. Pins match upstream (actionlint v1.7.12 with go.yaml.in/yaml/v4 v4.0.0-rc.3 — the two are version-coupled and a free resolution of actionlint does not build) and go 1.26, which exprparser needs for reflect.Fields. Upstream MIT notices retained; ours added above them. All four packages green. Co-authored-by: Hanzo Dev <[email protected]>
91 lines
2.2 KiB
Go
91 lines
2.2 KiB
Go
// Copyright 2026 Hanzo AI, Inc. All rights reserved.
|
|
// Copyright 2026 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package common
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
"sync/atomic"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
// Simple fast test that verifies max-parallel: 2 limits concurrency
|
|
func TestMaxParallel2Quick(t *testing.T) {
|
|
ctx := context.Background()
|
|
|
|
var currentRunning atomic.Int32
|
|
var maxSimultaneous atomic.Int32
|
|
|
|
executors := make([]Executor, 4)
|
|
for i := range 4 {
|
|
executors[i] = func(ctx context.Context) error {
|
|
current := currentRunning.Add(1)
|
|
|
|
// Update max if needed
|
|
for {
|
|
maxValue := maxSimultaneous.Load()
|
|
if current <= maxValue || maxSimultaneous.CompareAndSwap(maxValue, current) {
|
|
break
|
|
}
|
|
}
|
|
|
|
time.Sleep(10 * time.Millisecond)
|
|
currentRunning.Add(-1)
|
|
return nil
|
|
}
|
|
}
|
|
|
|
err := NewParallelExecutor(2, executors...)(ctx)
|
|
|
|
assert.NoError(t, err) //nolint:testifylint // pre-existing issue from nektos/act
|
|
assert.LessOrEqual(t, maxSimultaneous.Load(), int32(2),
|
|
"Should not exceed max-parallel: 2")
|
|
}
|
|
|
|
// Test that verifies max-parallel: 1 enforces sequential execution
|
|
func TestMaxParallel1Sequential(t *testing.T) {
|
|
ctx := context.Background()
|
|
|
|
var currentRunning atomic.Int32
|
|
var maxSimultaneous atomic.Int32
|
|
var executionOrder []int
|
|
var orderMutex sync.Mutex
|
|
|
|
executors := make([]Executor, 5)
|
|
for i := range 5 {
|
|
taskID := i
|
|
executors[i] = func(ctx context.Context) error {
|
|
current := currentRunning.Add(1)
|
|
|
|
// Track execution order
|
|
orderMutex.Lock()
|
|
executionOrder = append(executionOrder, taskID)
|
|
orderMutex.Unlock()
|
|
|
|
// Update max if needed
|
|
for {
|
|
maxValue := maxSimultaneous.Load()
|
|
if current <= maxValue || maxSimultaneous.CompareAndSwap(maxValue, current) {
|
|
break
|
|
}
|
|
}
|
|
|
|
time.Sleep(20 * time.Millisecond)
|
|
currentRunning.Add(-1)
|
|
return nil
|
|
}
|
|
}
|
|
|
|
err := NewParallelExecutor(1, executors...)(ctx)
|
|
|
|
assert.NoError(t, err) //nolint:testifylint // pre-existing issue from nektos/act
|
|
assert.Equal(t, int32(1), maxSimultaneous.Load(),
|
|
"max-parallel: 1 should only run 1 task at a time")
|
|
assert.Len(t, executionOrder, 5, "All 5 tasks should have executed")
|
|
}
|