[#799] scheduler: fix: skipIfSuccessful skips too much (#811)

dagu-org · Feb 6, 2025 · 39f0ce8 · 39f0ce8
1 parent 9344144
commit 39f0ce8
Show file tree

Hide file tree

Showing 11 changed files with 704 additions and 509 deletions.
diff --git a/cmd/setup.go b/cmd/setup.go
@@ -142,7 +142,9 @@ func (s *setup) scheduler() (*scheduler.Scheduler, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to initialize client: %w", err)
 	}
-	return scheduler.New(s.cfg, cli), nil
+
+	manager := scheduler.NewDAGJobManager(s.cfg.Paths.DAGsDir, cli, s.cfg.Paths.Executable, s.cfg.WorkDir)
+	return scheduler.New(s.cfg, manager), nil
 }
 
 func (s *setup) dagStore() (persistence.DAGStore, error) {

diff --git a/internal/scheduler/common_test.go b/internal/scheduler/common_test.go
diff --git a/internal/scheduler/entryreader.go b/internal/scheduler/entryreader.go
diff --git a/internal/scheduler/entryreader_test.go b/internal/scheduler/entryreader_test.go