oops

PeerDB-io · Oct 22, 2024 · 2e030a7 · 2e030a7
1 parent f2d8b1b
commit 2e030a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/activities/snapshot_activity.go b/flow/activities/snapshot_activity.go
@@ -85,7 +85,7 @@ func (a *SnapshotActivity) SetupReplication(
 
 	for {
 		var slotName string
-		if err := a.CatalogPool.QueryRow(ctx, "select slot_name from snapshot_names").Scan(&slotName); err == nil && slotName != "" {
+		if err := a.CatalogPool.QueryRow(ctx, "select slot_name from snapshot_names where flow_name = $1", config.FlowJobName).Scan(&slotName); err == nil && slotName != "" {
 			if err := conn.ExecuteCommand(
 				ctx,
 				"select pg_drop_replication_slot($1)",