From f92f4b336dd66d3195ba48a5f38cfedd65bdbcc4 Mon Sep 17 00:00:00 2001
From: Amogh-Bharadwaj <amogh@peerdb.io>
Date: Mon, 22 Jan 2024 20:17:12 +0530
Subject: [PATCH] remove check for duplicate dest

---
 nexus/server/src/main.rs | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/nexus/server/src/main.rs b/nexus/server/src/main.rs
index 4a1eebe7e1..ef9c97737d 100644
--- 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(),
-                                    ));
-                                }
                             }
                         }