From 73dc4bda509f7841f0c195900d7ab8bb09729c16 Mon Sep 17 00:00:00 2001
From: mrveiss <martins.veiss@gmail.com>
Date: Mon, 16 Mar 2026 20:29:48 +0200
Subject: [PATCH] fix: use db_service.session() instead of get_session() in
 a2a_card_fetcher (#1876)

Replace 4 calls to nonexistent get_session() with the correct
session() context manager API. Fixes AttributeError on every
5-minute A2A card refresh cycle.
---
 autobot-slm-backend/services/a2a_card_fetcher.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/autobot-slm-backend/services/a2a_card_fetcher.py b/autobot-slm-backend/services/a2a_card_fetcher.py
index d634219c0..ce01a9089 100644
--- a/autobot-slm-backend/services/a2a_card_fetcher.py
+++ b/autobot-slm-backend/services/a2a_card_fetcher.py
@@ -80,7 +80,7 @@ async def fetch_card_for_node(node_id: str) -> Optional[Dict[str, Any]]:
     from services.database import db_service
     from sqlalchemy import select
 
-    async with db_service.get_session() as db:
+    async with db_service.session() as db:
         result = await db.execute(select(Node).where(Node.node_id == node_id))
         node = result.scalar_one_or_none()
         if node is None:
@@ -103,7 +103,7 @@ async def _refresh_all_backend_nodes() -> None:
     from services.database import db_service
     from sqlalchemy import select
 
-    async with db_service.get_session() as db:
+    async with db_service.session() as db:
         result = await db.execute(
             select(Node).where(Node.status.in_(["online", "enrolled"]))
         )
@@ -177,7 +177,7 @@ async def fetch_card_for_external(agent_id: int) -> Optional[Dict[str, Any]]:
     from services.database import db_service
     from sqlalchemy import select, update
 
-    async with db_service.get_session() as db:
+    async with db_service.session() as db:
         result = await db.execute(
             select(ExternalAgent).where(ExternalAgent.id == agent_id)
         )
@@ -215,7 +215,7 @@ async def _refresh_all_external_agents() -> None:
     from services.database import db_service
     from sqlalchemy import select
 
-    async with db_service.get_session() as db:
+    async with db_service.session() as db:
         result = await db.execute(
             select(ExternalAgent).where(ExternalAgent.enabled.is_(True))
         )