From 6aab68063c41f6bdb6e05cf0c4e207d5cccf93f8 Mon Sep 17 00:00:00 2001 From: Martin Schmidt Date: Tue, 2 Dec 2025 21:10:01 +0100 Subject: [PATCH] fix: Reintroduce stop all pods on workflow (#5815) --- pipeline/backend/kubernetes/kubernetes.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/pipeline/backend/kubernetes/kubernetes.go b/pipeline/backend/kubernetes/kubernetes.go index 8262061464..02d2ab869d 100644 --- a/pipeline/backend/kubernetes/kubernetes.go +++ b/pipeline/backend/kubernetes/kubernetes.go @@ -455,6 +455,15 @@ func (e *kube) DestroyStep(ctx context.Context, step *types.Step, taskUUID strin func (e *kube) DestroyWorkflow(ctx context.Context, conf *types.Config, taskUUID string) error { log.Trace().Str("taskUUID", taskUUID).Msg("deleting Kubernetes primitives") + for _, stage := range conf.Stages { + for _, step := range stage.Steps { + err := stopPod(ctx, e, step, defaultDeleteOptions) + if err != nil { + return err + } + } + } + namespace := e.config.GetNamespace(conf.Stages[0].Steps[0].OrgID) log.Trace().Str("taskUUID", taskUUID).Msgf("deleting workflow headless service")