Record slot size: select distinct

Turns out we create a flows record per source/destination table pair
PeerDB-io · Mar 4, 2024 · e9c0743 · e9c0743
1 parent 15c9a0e
commit e9c0743
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -852,7 +852,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 WHERE query_string IS NULL")
+	rows, err := a.CatalogPool.Query(ctx, "SELECT DISTINCT flows.name, flows.config_proto FROM flows WHERE query_string IS NULL")
 	if err != nil {
 		return err
 	}