From a6574492bed803132b7ed7d123884e1561f57f73 Mon Sep 17 00:00:00 2001 From: Yaroslav Litvinov Date: Wed, 19 Feb 2025 01:40:27 +0200 Subject: [PATCH] in login request use database_name instead of warehouse --- crates/nexus/src/http/dbt/handlers.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/crates/nexus/src/http/dbt/handlers.rs b/crates/nexus/src/http/dbt/handlers.rs index d31badfda..8e9588da0 100644 --- a/crates/nexus/src/http/dbt/handlers.rs +++ b/crates/nexus/src/http/dbt/handlers.rs @@ -60,7 +60,11 @@ pub async fn login( .await .context(dbt_error::ControlServiceSnafu)?; - for warehouse in warehouses.into_iter().filter(|w| w.name == query.warehouse) { + debug!("login request query: {query:?}, databases: {warehouses:?}"); + for warehouse in warehouses + .into_iter() + .filter(|w| w.name == query.database_name) + { // Save warehouse id and db name in state state.dbt_sessions.lock().await.insert( token.clone(), @@ -128,7 +132,6 @@ pub async fn query( }; let sessions = state.dbt_sessions.lock().await; - let Some(_auth_data) = sessions.get(token.as_str()) else { return Err(DbtError::MissingDbtSession); };