remove check for duplicate dest

PeerDB-io · Jan 22, 2024 · f92f4b3 · f92f4b3
1 parent 8c5bb09
commit f92f4b3
Showing 1 changed file with 0 additions and 10 deletions.
diff --git a/nexus/server/src/main.rs b/nexus/server/src/main.rs
@@ -416,7 +416,6 @@ impl NexusBackend {
                         let table_mappings_count = flow_job.table_mappings.len();
                         if table_mappings_count > 1 {
                             let mut sources = HashSet::with_capacity(table_mappings_count);
-                            let mut destinations = HashSet::with_capacity(table_mappings_count);
                             for tm in flow_job.table_mappings.iter() {
                                 if !sources.insert(tm.source_table_identifier.as_str()) {
                                     return Err(PgWireError::ApiError(
@@ -427,15 +426,6 @@ impl NexusBackend {
                                         .into(),
                                     ));
                                 }
-                                if !destinations.insert(tm.destination_table_identifier.as_str()) {
-                                    return Err(PgWireError::ApiError(
-                                        format!(
-                                            "Duplicate destination table identifier {}",
-                                            tm.destination_table_identifier
-                                        )
-                                        .into(),
-                                    ));
-                                }
                             }
                         }