From 5c7f00d19f4bc31e2d86933f4eaff1a0ff7f1aef Mon Sep 17 00:00:00 2001 From: Jeff Ortel Date: Mon, 10 Jun 2024 14:52:39 -0700 Subject: [PATCH] :bug: fix restart on pod not-found. Signed-off-by: Jeff Ortel --- task/manager.go | 25 ++++++++++++------------- 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/task/manager.go b/task/manager.go index f93a31da..f2aa7108 100644 --- a/task/manager.go +++ b/task/manager.go @@ -786,19 +786,18 @@ func (m *Manager) updateRunning() { } running := task pod, found := running.Reflect(m.cluster) - if !found { - continue - } - if task.StateIn(Succeeded, Failed) { - err = m.podSnapshot(running, pod) - if err != nil { - Log.Error(err, "") - continue - } - err = running.Delete(m.Client) - if err != nil { - Log.Error(err, "") - continue + if found { + if task.StateIn(Succeeded, Failed) { + err = m.podSnapshot(running, pod) + if err != nil { + Log.Error(err, "") + continue + } + err = running.Delete(m.Client) + if err != nil { + Log.Error(err, "") + continue + } } } err = m.DB.Save(&running).Error