From 41c8dbed3ef4f238b50eb003bf78787e3287009d Mon Sep 17 00:00:00 2001
From: Johnny Graettinger <johnny@estuary.dev>
Date: Thu, 16 Jan 2025 19:47:47 -0600
Subject: [PATCH] Revert "broker: tear down a stale append pipeline before
 proxying"

This reverts commit ad2a8c9b95ff678bfc658f9c24545bde2deee98b.
---
 broker/append_fsm.go | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/broker/append_fsm.go b/broker/append_fsm.go
index c1a7df31..f8b49023 100644
--- a/broker/append_fsm.go
+++ b/broker/append_fsm.go
@@ -154,11 +154,7 @@ func (b *appendFSM) onResolve() {
 		b.state = stateError
 	} else if b.resolved.ProcessId != b.resolved.localID {
 		// If we hold the pipeline from a previous resolution but are no longer
-		// primary, we must tear it down to release replica spools.
-		if b.pln != nil {
-			go b.pln.shutdown(false)
-			b.pln = nil
-		}
+		// primary, we must release it.
 		b.returnPipeline()
 		b.state = stateAwaitDesiredReplicas // We must proxy.
 	} else if b.plnReturnCh != nil {