fix: admin

rudderlabs · Jul 7, 2023 · 5a0283b · 5a0283b
1 parent d13603c
commit 5a0283b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/warehouse/admin.go b/warehouse/admin.go
@@ -55,7 +55,7 @@ func (*WarehouseAdmin) Query(s QueryInput, reply *warehouseutils.QueryResult) er
 	}
 
 	var warehouse model.Warehouse
-	srcMap, ok := connectionsMap[s.DestID]
+	srcMap, ok := bcManager.ConnectionSourcesMap(s.DestID) // TODO remove global variable
 	if !ok {
 		return errors.New("please specify a valid and existing destination ID")
 	}
@@ -100,7 +100,7 @@ func (*WarehouseAdmin) ConfigurationTest(s ConfigurationTestInput, reply *Config
 	}
 
 	var warehouse model.Warehouse
-	srcMap, ok := connectionsMap[s.DestID]
+	srcMap, ok := bcManager.ConnectionSourcesMap(s.DestID) // TODO remove global variable
 	if !ok {
 		return fmt.Errorf("please specify a valid and existing destinationID: %s", s.DestID)
 	}