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 }