support pipeline pause

gaia-pipeline · Mar 23, 2022 · 348883d · 348883d
1 parent 95ab3b1
commit 348883d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/workers/scheduler/gaiascheduler/scheduler.go b/workers/scheduler/gaiascheduler/scheduler.go
@@ -171,7 +171,7 @@ func (s *Scheduler) work() {
 // prepareAndExec does the preparation and starts the execution.
 func (s *Scheduler) prepareAndExec(r gaia.PipelineRun) {
 	// Check the pipeline status, if it is PausedScheduled, exit this execution
-	if g, err := s.storeService.PipelineGetRunByID(r.UniqueID); err == nil {
+	if g, err := s.storeService.PipelineGetRunByID(r.UniqueID); err == nil && g != nil {
 		if g.Status == gaia.PausedScheduled {
 			return
 		}