deregister callback to avoid sending on closed channel

Signed-off-by: zachaller <[email protected]>
argoproj · Aug 8, 2023 · 24c9e81 · 24c9e81
1 parent e4cb311
commit 24c9e81
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/test/fixtures/when.go b/test/fixtures/when.go
@@ -345,6 +345,8 @@ func (w *When) WatchRolloutStatus(expectedStatus string, timeouts ...time.Durati
 	go controller.Run(ctx)
 	finalStatus := statusOptions.WatchStatus(ctx.Done(), rolloutUpdates)
 
+	controller.DeregisterCallbacks()
+
 	cancel()
 	close(rolloutUpdates)