patch

PeerDB-io · Dec 26, 2024 · 17035eb · 17035eb
1 parent 2182ae1
commit 17035eb
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -531,6 +531,9 @@ func (a *FlowableActivity) ReplicateQRepPartitions(ctx context.Context,
 		var err error
 		switch config.System {
 		case protos.TypeSystem_Q:
+			if config.DestinationTableIdentifier == "messages" {
+				return nil
+			}
 			stream := model.NewQRecordStream(shared.FetchAndChannelSize)
 			outstream := stream
 			if config.Script != "" {