From b65567433501854c5286d25eeb5f33058ae5f8e5 Mon Sep 17 00:00:00 2001 From: gamoutatsumi Date: Mon, 13 Nov 2023 16:38:18 +0900 Subject: [PATCH] add continue label --- pkg/starter/starter.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/starter/starter.go b/pkg/starter/starter.go index 8b5c7ab..f2de641 100644 --- a/pkg/starter/starter.go +++ b/pkg/starter/starter.go @@ -370,6 +370,7 @@ func (s *Starter) reRunWorkflow(ctx context.Context) { return true } + JL: // job loop for _, j := range jobs.Jobs { if value, ok := reQueuedJobs.Load(j.GetID()); ok { expired := value.(time.Time) @@ -380,7 +381,7 @@ func (s *Starter) reRunWorkflow(ctx context.Context) { } for _, label := range j.Labels { if !(strings.EqualFold(label, "self-hosted")) { - continue + continue JL } } if j.GetStatus() == "queued" {