From 9701c3aa0e549cbeacc20708354d64818a8c11ce Mon Sep 17 00:00:00 2001 From: Ishan Arya Date: Mon, 7 Aug 2023 10:43:16 +0530 Subject: [PATCH] fix: update stopped status dquote> - if the stoptime is in past, stopped flag value shall be updated to true as well --- modules/firehose/driver_sync.go | 1 + 1 file changed, 1 insertion(+) diff --git a/modules/firehose/driver_sync.go b/modules/firehose/driver_sync.go index 035e94be..bbd61df9 100644 --- a/modules/firehose/driver_sync.go +++ b/modules/firehose/driver_sync.go @@ -78,6 +78,7 @@ func (fd *firehoseDriver) Sync(ctx context.Context, exr module.ExpandedResource) finalState.NextSyncAt = conf.StopTime if conf.StopTime != nil && conf.StopTime.Before(fd.timeNow()) { conf.Replicas = 0 + conf.Stopped = true if err := fd.releaseSync(ctx, exr.Resource, false, *conf, kubeOut); err != nil { return nil, err }