remove continue

tilakraj94 · tilakraj94 · commit 6de33c3a49c2 · 2026-03-30T17:55:25.000+05:30
Signed-off-by: Tilak Raj &lt;tilak.raj94@gmail.com&gt;
diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go
@@ -1553,8 +1553,6 @@ func (js *jetStream) checkForOrphans() {
 			s.Noticef("Adopting orphaned R1 stream '%s > %s' into cluster assignments", accName, cfg.Name)
 			if err := meta.ForwardProposal(encodeAddStreamAssignment(sa)); err != nil {
 				s.Warnf("Failed to propose adoption of R1 stream '%s > %s': %v", accName, cfg.Name, err)
-				conflicts = true
-				continue
 			}
 
 			// Consumer adoption is deferred to the next sweep: once the stream

Original file line number	Diff line number	Diff line change
`@@ -1553,8 +1553,6 @@ func (js *jetStream) checkForOrphans() {`
`1553`	`1553`	`s.Noticef("Adopting orphaned R1 stream '%s > %s' into cluster assignments", accName, cfg.Name)`
`1554`	`1554`	`if err := meta.ForwardProposal(encodeAddStreamAssignment(sa)); err != nil {`
`1555`	`1555`	`s.Warnf("Failed to propose adoption of R1 stream '%s > %s': %v", accName, cfg.Name, err)`
`1556`		`- conflicts = true`
`1557`		`- continue`
`1558`	`1556`	`}`
`1559`	`1557`
`1560`	`1558`	`// Consumer adoption is deferred to the next sweep: once the stream`