From 846d2cb9a99a1e9cb9264354c08a24e2b32e8015 Mon Sep 17 00:00:00 2001
From: busya <uglypod@gmail.com>
Date: Thu, 4 Jun 2026 20:02:33 +0300
Subject: [PATCH] =?UTF-8?q?032:=20T019=20=E2=80=94=20remaining=20route=20f?=
 =?UTF-8?q?iles=20migrated=20to=20async=20SupersetClient?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

All routes (assistant, migration, datasets, git) now use AsyncSupersetClient.
_helpers.py sync->async for dashboard ref resolution.
_detail_routes.py import fixed.

Known residual: MigrationDryRunService and IdMappingService still sync.
---
 backend/src/api/routes/assistant/_dispatch.py |  8 ++++----
 .../src/api/routes/assistant/_resolvers.py    |  8 ++++----
 .../src/api/routes/assistant/_tool_backup.py  |  4 ++--
 .../src/api/routes/assistant/_tool_commit.py  |  2 +-
 .../routes/assistant/_tool_create_branch.py   |  2 +-
 .../src/api/routes/assistant/_tool_deploy.py  |  2 +-
 .../routes/assistant/_tool_llm_validation.py  |  2 +-
 .../api/routes/assistant/_tool_migration.py   |  2 +-
 .../assistant/_tool_search_dashboards.py      |  2 +-
 .../api/routes/dashboards/_detail_routes.py   | 12 +++++------
 backend/src/api/routes/datasets.py            | 20 +++++++++----------
 backend/src/api/routes/git/_helpers.py        | 12 +++++------
 backend/src/api/routes/git/_merge_routes.py   | 10 +++++-----
 .../api/routes/git/_repo_lifecycle_routes.py  |  6 +++---
 .../api/routes/git/_repo_operations_routes.py | 14 ++++++-------
 backend/src/api/routes/git/_repo_routes.py    | 14 ++++++-------
 backend/src/api/routes/migration.py           | 12 +++++------
 17 files changed, 66 insertions(+), 66 deletions(-)

diff --git a/backend/src/api/routes/assistant/_dispatch.py b/backend/src/api/routes/assistant/_dispatch.py
index e2f53299..a616c810 100644
--- a/backend/src/api/routes/assistant/_dispatch.py
+++ b/backend/src/api/routes/assistant/_dispatch.py
@@ -161,11 +161,11 @@ async def _async_confirmation_summary(intent: dict[str, Any], config_manager: Co
             if dry_run_enabled:
                 try:
                     from src.core.migration.dry_run_orchestrator import MigrationDryRunService
-                    from src.core.superset_client import SupersetClient
+                    from src.core.async_superset_client import AsyncSupersetClient
                     from src.models.dashboard import DashboardSelection
                     src_token = entities.get('source_env')
                     tgt_token = entities.get('target_env')
-                    dashboard_id = _resolve_dashboard_id_entity(entities, config_manager, env_hint=src_token)
+                    dashboard_id = await _resolve_dashboard_id_entity(entities, config_manager, env_hint=src_token)
                     if dashboard_id and src_token and tgt_token:
                         src_env_id = _resolve_env_id(src_token, config_manager)
                         tgt_env_id = _resolve_env_id(tgt_token, config_manager)
@@ -176,8 +176,8 @@ async def _async_confirmation_summary(intent: dict[str, Any], config_manager: Co
                             if source_env and target_env and (source_env.id != target_env.id):
                                 selection = DashboardSelection(source_env_id=source_env.id, target_env_id=target_env.id, selected_ids=[dashboard_id], replace_db_config=_coerce_query_bool(entities.get('replace_db_config', False)), fix_cross_filters=_coerce_query_bool(entities.get('fix_cross_filters', True)))
                                 service = MigrationDryRunService()
-                                source_client = SupersetClient(source_env)
-                                target_client = SupersetClient(target_env)
+                                source_client = AsyncSupersetClient(source_env)
+                                target_client = AsyncSupersetClient(target_env)
                                 report = service.run(selection, source_client, target_client, db)
                                 s = report.get('summary', {})
                                 dash_s = s.get('dashboards', {})
diff --git a/backend/src/api/routes/assistant/_resolvers.py b/backend/src/api/routes/assistant/_resolvers.py
index 39f2c54d..5a54d575 100644
--- a/backend/src/api/routes/assistant/_resolvers.py
+++ b/backend/src/api/routes/assistant/_resolvers.py
@@ -137,7 +137,7 @@ def _get_default_environment_id(config_manager: ConfigManager) -> str | None:
 # @BRIEF Resolve dashboard id by title or slug reference in selected environment.
 # @PRE  dashboard_ref is a non-empty string-like token.
 # @POST  Returns dashboard id when uniquely matched, otherwise None.
-def _resolve_dashboard_id_by_ref(
+async def _resolve_dashboard_id_by_ref(
     dashboard_ref: str | None,
     env_id: str | None,
     config_manager: ConfigManager,
@@ -153,7 +153,7 @@ def _resolve_dashboard_id_by_ref(
     needle = dashboard_ref.strip().lower()
     try:
         client = SupersetClient(env)
-        _, dashboards = client.get_dashboards(query={"page_size": 200})
+        _, dashboards = await client.get_dashboards(query={"page_size": 200})
     except Exception as exc:
         logger.warning(
             f"[assistant.dashboard_resolve][failed] ref={dashboard_ref} env={env_id} error={exc}"
@@ -189,7 +189,7 @@ def _resolve_dashboard_id_by_ref(
 # @BRIEF Resolve dashboard id from intent entities using numeric id or dashboard_ref fallback.
 # @PRE  entities may contain dashboard_id as int/str and optional dashboard_ref.
 # @POST  Returns resolved dashboard id or None when ambiguous/unresolvable.
-def _resolve_dashboard_id_entity(
+async def _resolve_dashboard_id_entity(
     entities: dict[str, Any],
     config_manager: ConfigManager,
     env_hint: str | None = None,
@@ -221,7 +221,7 @@ def _resolve_dashboard_id_entity(
         if env_token
         else _get_default_environment_id(config_manager)
     )
-    return _resolve_dashboard_id_by_ref(str(dashboard_ref), env_id, config_manager)
+    return await _resolve_dashboard_id_by_ref(str(dashboard_ref), env_id, config_manager)
 
 
 # #endregion _resolve_dashboard_id_entity
diff --git a/backend/src/api/routes/assistant/_tool_backup.py b/backend/src/api/routes/assistant/_tool_backup.py
index 68598999..24b73262 100644
--- a/backend/src/api/routes/assistant/_tool_backup.py
+++ b/backend/src/api/routes/assistant/_tool_backup.py
@@ -59,7 +59,7 @@ async def handle_run_backup(
         raise HTTPException(status_code=400, detail="Missing or unknown environment")
     params: dict[str, Any] = {"environment_id": env_id}
     if entities.get("dashboard_id") or entities.get("dashboard_ref"):
-        dashboard_id = _resolve_dashboard_id_entity(
+        dashboard_id = await _resolve_dashboard_id_entity(
             entities, config_manager, env_hint=env_token
         )
         if not dashboard_id:
@@ -77,7 +77,7 @@ async def handle_run_backup(
         ),
     ]
     if entities.get("dashboard_id") or entities.get("dashboard_ref"):
-        dashboard_id = _resolve_dashboard_id_entity(
+        dashboard_id = await _resolve_dashboard_id_entity(
             entities, config_manager, env_hint=env_token
         )
         if dashboard_id:
diff --git a/backend/src/api/routes/assistant/_tool_commit.py b/backend/src/api/routes/assistant/_tool_commit.py
index 327ba6e4..00fab6bf 100644
--- a/backend/src/api/routes/assistant/_tool_commit.py
+++ b/backend/src/api/routes/assistant/_tool_commit.py
@@ -44,7 +44,7 @@ async def handle_commit_changes(
     """Commit dashboard repository changes."""
     _check_any_permission(current_user, [("plugin:git", "EXECUTE")])
     entities = intent.get("entities", {})
-    dashboard_id = _resolve_dashboard_id_entity(entities, config_manager)
+    dashboard_id = await _resolve_dashboard_id_entity(entities, config_manager)
     commit_message = entities.get("message")
     if not dashboard_id:
         raise HTTPException(status_code=422, detail="Missing dashboard_id/dashboard_ref")
diff --git a/backend/src/api/routes/assistant/_tool_create_branch.py b/backend/src/api/routes/assistant/_tool_create_branch.py
index 82b5caac..55231ea2 100644
--- a/backend/src/api/routes/assistant/_tool_create_branch.py
+++ b/backend/src/api/routes/assistant/_tool_create_branch.py
@@ -45,7 +45,7 @@ async def handle_create_branch(
     """Create git branch for dashboard by id/slug/title."""
     _check_any_permission(current_user, [("plugin:git", "EXECUTE")])
     entities = intent.get("entities", {})
-    dashboard_id = _resolve_dashboard_id_entity(entities, config_manager)
+    dashboard_id = await _resolve_dashboard_id_entity(entities, config_manager)
     branch_name = entities.get("branch_name")
     if not dashboard_id or not branch_name:
         raise HTTPException(
diff --git a/backend/src/api/routes/assistant/_tool_deploy.py b/backend/src/api/routes/assistant/_tool_deploy.py
index 10162a8e..ca1cc400 100644
--- a/backend/src/api/routes/assistant/_tool_deploy.py
+++ b/backend/src/api/routes/assistant/_tool_deploy.py
@@ -45,7 +45,7 @@ async def handle_deploy_dashboard(
     entities = intent.get("entities", {})
     env_token = entities.get("environment")
     env_id = _resolve_env_id(env_token, config_manager)
-    dashboard_id = _resolve_dashboard_id_entity(
+    dashboard_id = await _resolve_dashboard_id_entity(
         entities, config_manager, env_hint=env_token
     )
     if not dashboard_id or not env_id:
diff --git a/backend/src/api/routes/assistant/_tool_llm_validation.py b/backend/src/api/routes/assistant/_tool_llm_validation.py
index 7c2e1ddb..da8da51e 100644
--- a/backend/src/api/routes/assistant/_tool_llm_validation.py
+++ b/backend/src/api/routes/assistant/_tool_llm_validation.py
@@ -59,7 +59,7 @@ async def handle_run_llm_validation(
     env_id = _resolve_env_id(env_token, config_manager) or _resolve_env_id(
         None, config_manager
     )
-    dashboard_id = _resolve_dashboard_id_entity(
+    dashboard_id = await _resolve_dashboard_id_entity(
         entities, config_manager, env_hint=env_token
     )
     provider_id = _resolve_provider_id(
diff --git a/backend/src/api/routes/assistant/_tool_migration.py b/backend/src/api/routes/assistant/_tool_migration.py
index d49577c7..37492170 100644
--- a/backend/src/api/routes/assistant/_tool_migration.py
+++ b/backend/src/api/routes/assistant/_tool_migration.py
@@ -64,7 +64,7 @@ async def handle_execute_migration(
     entities = intent.get("entities", {})
     src_token = entities.get("source_env")
     dashboard_ref = entities.get("dashboard_ref")
-    dashboard_id = _resolve_dashboard_id_entity(
+    dashboard_id = await _resolve_dashboard_id_entity(
         entities, config_manager, env_hint=src_token
     )
     src = _resolve_env_id(src_token, config_manager)
diff --git a/backend/src/api/routes/assistant/_tool_search_dashboards.py b/backend/src/api/routes/assistant/_tool_search_dashboards.py
index ce42b800..56e518b2 100644
--- a/backend/src/api/routes/assistant/_tool_search_dashboards.py
+++ b/backend/src/api/routes/assistant/_tool_search_dashboards.py
@@ -66,7 +66,7 @@ async def handle_search_dashboards(
         return (f"Окружение {env_id} не найдено.", None, [])
 
     client = SupersetClient(env)
-    all_dashboards = client.get_dashboards_summary(require_slug=True)
+    all_dashboards = await client.get_dashboards_summary(require_slug=True)
 
     # Filter by search term
     if search:
diff --git a/backend/src/api/routes/dashboards/_detail_routes.py b/backend/src/api/routes/dashboards/_detail_routes.py
index 010bb650..0be4d1d8 100644
--- a/backend/src/api/routes/dashboards/_detail_routes.py
+++ b/backend/src/api/routes/dashboards/_detail_routes.py
@@ -13,7 +13,7 @@ from urllib.parse import urlparse
 from fastapi import Depends, HTTPException, Query, Response
 from fastapi.responses import JSONResponse
 
-from src.core.async_superset_client import AsyncSupersetClient
+from src.core.superset_client import SupersetClient
 from src.core.logger import belief_scope, logger
 from src.core.utils.client_registry import get_client as get_superset_client
 from src.core.utils.network import DashboardNotFoundError
@@ -110,7 +110,7 @@ async def get_database_mappings(
 # @BRIEF Fetch detailed dashboard info with related charts and datasets
 # @PRE  env_id must be valid and dashboard ref (slug or id) must exist
 # @POST  Returns dashboard detail payload for overview page
-# @RELATION CALLS -> [AsyncSupersetClient]
+# @RELATION CALLS -> [SupersetClient]
 @router.get("/{dashboard_ref}", response_model=DashboardDetailResponse)
 async def get_dashboard_detail(
     dashboard_ref: str,
@@ -142,7 +142,7 @@ async def get_dashboard_detail(
                 "verify_ssl": env.verify_ssl,
             }
             async_client = await get_superset_client(env_config)
-            client = AsyncSupersetClient(env)
+            client = SupersetClient(env)
             dashboard_id = await _resolve_dashboard_id_from_ref_async(
                 dashboard_ref, client
             )
@@ -183,7 +183,7 @@ async def get_dashboard_tasks_history(
         f"dashboard_ref={dashboard_ref}, env_id={env_id}, limit={limit}",
     ):
         dashboard_id: int | None = None
-        client: AsyncSupersetClient | None = None
+        client: SupersetClient | None = None
         try:
             if dashboard_ref.isdigit():
                 dashboard_id = int(dashboard_ref)
@@ -195,7 +195,7 @@ async def get_dashboard_tasks_history(
                         f"[get_dashboard_tasks_history][Coherence:Failed] Environment not found: {env_id}"
                     )
                     raise HTTPException(status_code=404, detail="Environment not found")
-                client = AsyncSupersetClient(env)
+                client = SupersetClient(env)
                 dashboard_id = await _resolve_dashboard_id_from_ref_async(
                     dashboard_ref, client
                 )
@@ -305,7 +305,7 @@ async def get_dashboard_thumbnail(
                 "verify_ssl": env.verify_ssl,
             }
             async_client = await get_superset_client(env_config)
-            client = AsyncSupersetClient(env)
+            client = SupersetClient(env)
             dashboard_id = await _resolve_dashboard_id_from_ref_async(
                 dashboard_ref, client
             )
diff --git a/backend/src/api/routes/datasets.py b/backend/src/api/routes/datasets.py
index d71eb292..7ede9f02 100644
--- a/backend/src/api/routes/datasets.py
+++ b/backend/src/api/routes/datasets.py
@@ -19,7 +19,7 @@ from fastapi import APIRouter, Depends, HTTPException, Query
 from pydantic import BaseModel, ConfigDict, Field
 
 from ...core.logger import belief_scope, logger
-from ...core.superset_client import SupersetClient
+from ...core.async_superset_client import AsyncSupersetClient
 from ...dependencies import get_config_manager, get_resource_service, get_task_manager, has_permission
 
 router = APIRouter(prefix="/api/datasets", tags=["Datasets"])
@@ -468,9 +468,9 @@ async def get_dataset_detail(
             raise HTTPException(status_code=404, detail="Environment not found")
 
         try:
-            # Fetch detailed dataset info using SupersetClient
-            client = SupersetClient(env)
-            dataset_detail = client.get_dataset_detail(dataset_id)
+            # Fetch detailed dataset info using AsyncSupersetClient
+            client = AsyncSupersetClient(env)
+            dataset_detail = await client.get_dataset_detail(dataset_id)
 
             # Normalize 'database' field: Superset returns an object, model expects a string
             if isinstance(dataset_detail.get("database"), dict):
@@ -536,13 +536,13 @@ async def update_column_description(
             raise HTTPException(status_code=404, detail="Environment not found")
 
         try:
-            client = SupersetClient(env)
+            client = AsyncSupersetClient(env)
 
             # GET full dataset
             logger.reason("Fetching full dataset from Superset for column description update",
                           extra={"src": "update_column_description"})
             try:
-                response = client.get_dataset(dataset_id)
+                response = await client.get_dataset(dataset_id)
             except Exception as e:
                 logger.error(f"[update_column_description][Coherence:Failed] Superset GET failed: {e}")
                 raise HTTPException(status_code=502, detail=f"Failed to fetch dataset from Superset: {e!s}")
@@ -572,7 +572,7 @@ async def update_column_description(
             # PUT back with override_columns=false
             put_payload = dataset
             try:
-                client.update_dataset(dataset_id, put_payload, override_columns=False)
+                await client.update_dataset(dataset_id, put_payload, override_columns=False)
             except Exception as e:
                 logger.error(f"[update_column_description][Coherence:Failed] Superset PUT failed: {e}")
                 raise HTTPException(status_code=502, detail=f"Failed to update dataset in Superset: {e!s}")
@@ -623,13 +623,13 @@ async def update_metric_description(
             raise HTTPException(status_code=404, detail="Environment not found")
 
         try:
-            client = SupersetClient(env)
+            client = AsyncSupersetClient(env)
 
             # GET full dataset
             logger.reason("Fetching full dataset from Superset for metric description update",
                           extra={"src": "update_metric_description"})
             try:
-                response = client.get_dataset(dataset_id)
+                response = await client.get_dataset(dataset_id)
             except Exception as e:
                 logger.error(f"[update_metric_description][Coherence:Failed] Superset GET failed: {e}")
                 raise HTTPException(status_code=502, detail=f"Failed to fetch dataset from Superset: {e!s}")
@@ -658,7 +658,7 @@ async def update_metric_description(
 
             # PUT back with override_columns=false
             try:
-                client.update_dataset(dataset_id, dataset, override_columns=False)
+                await client.update_dataset(dataset_id, dataset, override_columns=False)
             except Exception as e:
                 logger.error(f"[update_metric_description][Coherence:Failed] Superset PUT failed: {e}")
                 raise HTTPException(status_code=502, detail=f"Failed to update dataset in Superset: {e!s}")
diff --git a/backend/src/api/routes/git/_helpers.py b/backend/src/api/routes/git/_helpers.py
index c3e1650f..3e47b16c 100644
--- a/backend/src/api/routes/git/_helpers.py
+++ b/backend/src/api/routes/git/_helpers.py
@@ -90,7 +90,7 @@ def _get_git_config_or_404(db: Session, config_id: str) -> GitServerConfig:
 
 # #region _find_dashboard_id_by_slug [C:2] [TYPE Function]
 # @BRIEF Resolve dashboard numeric ID by slug in a specific environment.
-def _find_dashboard_id_by_slug(
+async def _find_dashboard_id_by_slug(
     client: SupersetClient,
     dashboard_slug: str,
 ) -> int | None:
@@ -109,7 +109,7 @@ def _find_dashboard_id_by_slug(
 
     for query in query_variants:
         try:
-            _count, dashboards = client.get_dashboards_page(query=query)
+            _count, dashboards = await client.get_dashboards_page(query=query)
             if dashboards:
                 resolved_id = dashboards[0].get("id")
                 if resolved_id is not None:
@@ -122,7 +122,7 @@ def _find_dashboard_id_by_slug(
 
 # #region _resolve_dashboard_id_from_ref [C:2] [TYPE Function]
 # @BRIEF Resolve dashboard ID from slug-or-id reference for Git routes.
-def _resolve_dashboard_id_from_ref(
+async def _resolve_dashboard_id_from_ref(
     dashboard_ref: str,
     config_manager,
     env_id: str | None = None,
@@ -145,7 +145,7 @@ def _resolve_dashboard_id_from_ref(
     if not env:
         raise HTTPException(status_code=404, detail="Environment not found")
 
-    dashboard_id = _find_dashboard_id_by_slug(SupersetClient(env), normalized_ref)
+    dashboard_id = await _find_dashboard_id_by_slug(SupersetClient(env), normalized_ref)
     if dashboard_id is None:
         raise HTTPException(
             status_code=404, detail=f"Dashboard slug '{normalized_ref}' not found"
@@ -228,7 +228,7 @@ async def _resolve_dashboard_id_from_ref_async(
 
 # #region _resolve_repo_key_from_ref [C:2] [TYPE Function]
 # @BRIEF Resolve repository folder key with slug-first strategy and deterministic fallback.
-def _resolve_repo_key_from_ref(
+async def _resolve_repo_key_from_ref(
     dashboard_ref: str,
     dashboard_id: int,
     config_manager,
@@ -243,7 +243,7 @@ def _resolve_repo_key_from_ref(
             environments = config_manager.get_environments()
             env = next((e for e in environments if e.id == env_id), None)
             if env:
-                payload = SupersetClient(env).get_dashboard(dashboard_id)
+                payload = await SupersetClient(env).get_dashboard(dashboard_id)
                 dashboard_data = (
                     payload.get("result", payload) if isinstance(payload, dict) else {}
                 )
diff --git a/backend/src/api/routes/git/_merge_routes.py b/backend/src/api/routes/git/_merge_routes.py
index 41eb9e07..dd755750 100644
--- a/backend/src/api/routes/git/_merge_routes.py
+++ b/backend/src/api/routes/git/_merge_routes.py
@@ -37,7 +37,7 @@ async def get_merge_status(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.get_merge_status(dashboard_id)
@@ -65,7 +65,7 @@ async def get_merge_conflicts(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.get_merge_conflicts(dashboard_id)
@@ -92,7 +92,7 @@ async def resolve_merge_conflicts(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             resolved_files = _gs.resolve_merge_conflicts(
@@ -121,7 +121,7 @@ async def abort_merge(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.abort_merge(dashboard_id)
@@ -148,7 +148,7 @@ async def continue_merge(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.continue_merge(dashboard_id, continue_data.message)
diff --git a/backend/src/api/routes/git/_repo_lifecycle_routes.py b/backend/src/api/routes/git/_repo_lifecycle_routes.py
index 9e107e05..7eb1e692 100644
--- a/backend/src/api/routes/git/_repo_lifecycle_routes.py
+++ b/backend/src/api/routes/git/_repo_lifecycle_routes.py
@@ -41,7 +41,7 @@ async def sync_dashboard(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             from src.plugins.git_plugin import GitPlugin
@@ -78,7 +78,7 @@ async def promote_dashboard(
     with belief_scope("promote_dashboard"):
         from . import _resolve_dashboard_id_from_ref
 
-        dashboard_id = _resolve_dashboard_id_from_ref(
+        dashboard_id = await _resolve_dashboard_id_from_ref(
             dashboard_ref, config_manager, env_id
         )
         db_repo = (
@@ -199,7 +199,7 @@ async def deploy_dashboard(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             from src.plugins.git_plugin import GitPlugin
diff --git a/backend/src/api/routes/git/_repo_operations_routes.py b/backend/src/api/routes/git/_repo_operations_routes.py
index 7ae56f1c..2b534dab 100644
--- a/backend/src/api/routes/git/_repo_operations_routes.py
+++ b/backend/src/api/routes/git/_repo_operations_routes.py
@@ -45,7 +45,7 @@ async def commit_changes(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             _apply_git_identity_from_profile(dashboard_id, db, current_user)
@@ -74,7 +74,7 @@ async def push_changes(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             _gs.push_changes(dashboard_id)
@@ -103,7 +103,7 @@ async def pull_changes(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             db_repo = None
@@ -161,7 +161,7 @@ async def get_repository_status(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _resolve_repository_status(dashboard_id)
@@ -227,7 +227,7 @@ async def get_repository_diff(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.get_diff(dashboard_id, file_path, staged)
@@ -253,7 +253,7 @@ async def get_history(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.get_commit_history(dashboard_id, limit)
@@ -280,7 +280,7 @@ async def generate_commit_message(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             diff = _gs.get_diff(dashboard_id, staged=True)
diff --git a/backend/src/api/routes/git/_repo_routes.py b/backend/src/api/routes/git/_repo_routes.py
index 9ad731ae..bc1609b8 100644
--- a/backend/src/api/routes/git/_repo_routes.py
+++ b/backend/src/api/routes/git/_repo_routes.py
@@ -44,10 +44,10 @@ async def init_repository(
     with belief_scope("init_repository"):
         from . import _resolve_dashboard_id_from_ref, _resolve_repo_key_from_ref
 
-        dashboard_id = _resolve_dashboard_id_from_ref(
+        dashboard_id = await _resolve_dashboard_id_from_ref(
             dashboard_ref, config_manager, env_id
         )
-        repo_key = _resolve_repo_key_from_ref(
+        repo_key = await _resolve_repo_key_from_ref(
             dashboard_ref, dashboard_id, config_manager, env_id
         )
         config = (
@@ -122,7 +122,7 @@ async def get_repository_binding(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             db_repo = (
@@ -163,7 +163,7 @@ async def delete_repository(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             _gs.delete_repo(dashboard_id)
@@ -189,7 +189,7 @@ async def get_branches(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             return _gs.list_branches(dashboard_id)
@@ -217,7 +217,7 @@ async def create_branch(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             _apply_git_identity_from_profile(dashboard_id, db, current_user)
@@ -247,7 +247,7 @@ async def checkout_branch(
         from . import _resolve_dashboard_id_from_ref
 
         try:
-            dashboard_id = _resolve_dashboard_id_from_ref(
+            dashboard_id = await _resolve_dashboard_id_from_ref(
                 dashboard_ref, config_manager, env_id
             )
             _gs.checkout_branch(dashboard_id, checkout_data.name)
diff --git a/backend/src/api/routes/migration.py b/backend/src/api/routes/migration.py
index 363c5c40..ad149525 100644
--- a/backend/src/api/routes/migration.py
+++ b/backend/src/api/routes/migration.py
@@ -30,7 +30,7 @@ from ...core.database import get_db
 from ...core.logger import belief_scope, logger
 from ...core.mapping_service import IdMappingService
 from ...core.migration.dry_run_orchestrator import MigrationDryRunService
-from ...core.superset_client import SupersetClient
+from ...core.async_superset_client import AsyncSupersetClient
 from ...dependencies import get_config_manager, get_task_manager, has_permission
 from ...models.dashboard import DashboardMetadata, DashboardSelection
 from ...models.mapping import ResourceMapping
@@ -62,8 +62,8 @@ async def get_dashboards(
             logger.explore(f"Environment {env_id} not found in configuration")
             raise HTTPException(status_code=404, detail="Environment not found")
 
-        client = SupersetClient(env)
-        dashboards = client.get_dashboards_summary()
+        client = AsyncSupersetClient(env)
+        dashboards = await client.get_dashboards_summary()
         logger.reflect(f"Retrieved {len(dashboards)} dashboards from {env_id}")
         return dashboards
 
@@ -180,8 +180,8 @@ async def dry_run_migration(
             )
 
         service = MigrationDryRunService()
-        source_client = SupersetClient(source_env)
-        target_client = SupersetClient(target_env)
+        source_client = AsyncSupersetClient(source_env)
+        target_client = AsyncSupersetClient(target_env)
 
         try:
             result = service.run(
@@ -373,7 +373,7 @@ async def trigger_sync_now(
 
         for env in environments:
             try:
-                client = SupersetClient(env)
+                client = AsyncSupersetClient(env)
                 service.sync_environment(env.id, client)
                 results["synced"].append(env.id)
                 logger.reason(f"Synced environment {env.id}", extra={"src": "trigger_sync_now"})