revert change

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)
 	}