test db merge sequential

internal/db/merge.go

@@ -46,18 +46,16 @@ func (db *db) handleMerges(ctx context.Context, sub *event.Subscription) {
 			if !ok {
 				continue
 			}
-			go func() {
-				err := db.executeMerge(ctx, merge)
-				if err != nil {
-					log.ErrorContextE(
-						ctx,
-						"Failed to execute merge",
-						err,
-						corelog.String("CID", merge.Cid.String()),
-						corelog.String("Error", err.Error()),
-					)
-				}
-			}()
+			err := db.executeMerge(ctx, merge)
+			if err != nil {
+				log.ErrorContextE(
+					ctx,
+					"Failed to execute merge",
+					err,
+					corelog.String("CID", merge.Cid.String()),
+					corelog.String("Error", err.Error()),
+				)
+			}
 		}
 	}
 }

internal/db/subscriptions.go

@@ -31,7 +31,6 @@ func (db *db) handleSubscription(ctx context.Context, r *request.Request) (<-cha
 	if !ok {
 		return nil, client.NewErrUnexpectedType[request.ObjectSubscription]("SubscriptionSelection", selections)
 	}
-	// subscribe to the subscription event bus so we don't block the system bus
 	sub, err := db.events.Subscribe(event.UpdateName)
 	if err != nil {
 		return nil, err

tests/integration/utils2.go

@@ -657,11 +657,6 @@ func setStartingNodes(
 
 		s.nodes = append(s.nodes, c)
 		s.dbPaths = append(s.dbPaths, path)
-
-		// subscribe to merge complete events
-		sub, err := c.Events().Subscribe(event.MergeCompleteName)
-		require.NoError(s.t, err)
-		s.eventSubs = append(s.eventSubs, sub)
 	}
 }