diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
index 8031aa584..ae0dbea52 100644
--- a/flow/connectors/postgres/postgres.go
+++ b/flow/connectors/postgres/postgres.go
@@ -1134,7 +1134,7 @@ func (c *PostgresConnector) PullFlowCleanup(ctx context.Context, jobName string)
 	// Slotname would be the job name prefixed with "peerflow_slot_"
 	slotName := "peerflow_slot_" + jobName
 	if _, err := c.conn.Exec(
-		ctx, `SELECT pg_drop_replication_slo(slot_name) FROM pg_replication_slots WHERE slot_name=$1`, slotName,
+		ctx, `SELECT pg_drop_replication_slot(slot_name) FROM pg_replication_slots WHERE slot_name=$1`, slotName,
 	); err != nil {
 		return fmt.Errorf("error dropping replication slot: %w", err)
 	}