only log err

grutt · grutt · commit cd5e7781728c · 2026-01-23T10:07:51.000-05:00
diff --git a/internal/msgqueue/olap_tee_queue.go b/internal/msgqueue/olap_tee_queue.go
@@ -78,7 +78,8 @@ func (m *OLAPTeeMessageQueue) SendMessage(ctx context.Context, queue Queue, msg
 	// Only OLAP queue messages are dual-written.
 	if m.standby != nil && queue != nil && queue.Name() == OLAP_QUEUE.Name() {
 		if err := m.standby.SendMessage(ctx, queue, msg); err != nil {
-			return err
+			// log the error but don't return it
+			fmt.Printf("MIGRATION failed to dual-write OLAP queue message to standby: %v\n", err)
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,8 @@ func (m *OLAPTeeMessageQueue) SendMessage(ctx context.Context, queue Queue, msg`
`78`	`78`	`// Only OLAP queue messages are dual-written.`
`79`	`79`	`if m.standby != nil && queue != nil && queue.Name() == OLAP_QUEUE.Name() {`
`80`	`80`	`if err := m.standby.SendMessage(ctx, queue, msg); err != nil {`
`81`		`- return err`
	`81`	`+ // log the error but don't return it`
	`82`	`+ fmt.Printf("MIGRATION failed to dual-write OLAP queue message to standby: %v\n", err)`
`82`	`83`	`}`
`83`	`84`	`}`
`84`	`85`