diff --git a/controllers/jetstream/stream.go b/controllers/jetstream/stream.go index 51d8bc5d..f87277c8 100644 --- a/controllers/jetstream/stream.go +++ b/controllers/jetstream/stream.go @@ -207,7 +207,7 @@ func (c *Controller) processStreamObject(str *apis.Stream, jsm jsmClientFunc) (e return err } updateOK := (strOK && !deleteOK && newGeneration) - createOK := (!strOK && !deleteOK) || (!deleteOK && newGeneration) + createOK := (!strOK && !deleteOK) || (!updateOK && !deleteOK && newGeneration) switch { case createOK: