diff --git a/Makefile b/Makefile index 34c9b56..f5d1a8c 100644 --- a/Makefile +++ b/Makefile @@ -318,7 +318,7 @@ github-release: export GORELEASER_CURRENT_TAG="$(VERSION)" && goreleaser release --clean github-action: - gh workflow run manual-release.yaml && gh workflow run nightly-release.yaml + unset GH_TOKEN &&gh workflow run manual-release.yaml && gh workflow run nightly-release.yaml # Database commands db-seed: build diff --git a/pkg/server/handlers/runs.go b/pkg/server/handlers/runs.go index 5e961ad..8038bad 100644 --- a/pkg/server/handlers/runs.go +++ b/pkg/server/handlers/runs.go @@ -160,6 +160,8 @@ func executeRunsConcurrently( maxConcurrency = 1 } + loader := parser.NewLoader(cfg.WorkflowsPath) + sem := make(chan struct{}, maxConcurrency) // Semaphore var wg sync.WaitGroup @@ -193,6 +195,7 @@ func executeRunsConcurrently( // Execute workflow exec := executor.NewExecutor() exec.SetServerMode(true) // Enable file logging for server mode + exec.SetLoader(loader) // Set up database progress tracking if runUUID != "" { @@ -370,6 +373,7 @@ func CreateRun(cfg *config.Config) fiber.Handler { exec := executor.NewExecutor() exec.SetServerMode(true) // Enable file logging for server mode + exec.SetLoader(loader) // Set up database progress tracking if run != nil { @@ -782,6 +786,7 @@ func StartRun(cfg *config.Config) fiber.Handler { // Create executor exec := executor.NewExecutor() exec.SetServerMode(true) + exec.SetLoader(loader) exec.SetDBRunUUID(runUUID) exec.SetDBRunID(runID) exec.SetOnStepCompleted(func(stepCtx context.Context, dbRunUUID string) {