From 91395ea1ab65cccf07b948e7f06bf9c9f33108bd Mon Sep 17 00:00:00 2001 From: Michael Parker Date: Thu, 9 Jan 2020 11:05:22 -0600 Subject: [PATCH] deepcopy canary for failed notification --- pkg/controller/scheduler.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/controller/scheduler.go b/pkg/controller/scheduler.go index 94e8a3ae..e9af0e2c 100644 --- a/pkg/controller/scheduler.go +++ b/pkg/controller/scheduler.go @@ -290,9 +290,12 @@ func (c *Controller) advanceCanary(name string, namespace string, skipLivenessCh return } + canaryPhaseFailed := cd.DeepCopy() + canaryPhaseFailed.Status.Phase = flaggerv1.CanaryPhaseFailed + c.recordEventWarningf(canaryPhaseFailed, "Canary failed! Scaling down %s.%s", + canaryPhaseFailed.Name, canaryPhaseFailed.Namespace) + c.recorder.SetWeight(cd, primaryWeight, canaryWeight) - c.recordEventWarningf(cd, "Canary failed! Scaling down %s.%s", - cd.Name, cd.Namespace) // shutdown canary if err := canaryController.Scale(cd, 0); err != nil {