21 lines
528 B
Go
21 lines
528 B
Go
package agent_execution_test
|
|
|
|
import (
|
|
"os"
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
func TestRecoveryMigrationDefinesBoundedRetryState(t *testing.T) {
|
|
payload, err := os.ReadFile("../../database/migrations/042_agent_execution_recovery.sql")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
source := strings.ToLower(string(payload))
|
|
for _, fragment := range []string{"set role work_role", "retry_limit integer not null default 3", "retry_limit > 0"} {
|
|
if !strings.Contains(source, fragment) {
|
|
t.Fatalf("migration is missing %q", fragment)
|
|
}
|
|
}
|
|
}
|