RecordSlotSize: ignore qrep/xmin mirrors (#1367)

PeerDB-io · Feb 23, 2024 · 58954df · 58954df
1 parent 00fd27d
commit 58954df
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -851,7 +851,7 @@ func (a *FlowableActivity) SendWALHeartbeat(ctx context.Context) error {
 }
 
 func (a *FlowableActivity) RecordSlotSizes(ctx context.Context) error {
-	rows, err := a.CatalogPool.Query(ctx, "SELECT flows.name, flows.config_proto FROM flows")
+	rows, err := a.CatalogPool.Query(ctx, "SELECT flows.name, flows.config_proto FROM flows WHERE query_string IS NULL")
 	if err != nil {
 		return err
 	}