Spaces:
Running
Running
Update app/app.py
Browse files- app/app.py +7 -3
app/app.py
CHANGED
|
@@ -216,12 +216,16 @@ async def start_application(fundaments: Dict[str, Any]) -> None:
|
|
| 216 |
|
| 217 |
# --- Initialize MCP (registers tools, prepares SSE handler) ---
|
| 218 |
# db_sync only if cloud_DB used to!
|
| 219 |
-
await db_sync.initialize()
|
| 220 |
# PSQL bridge — nur wenn Guardian DB-Service injiziert hat
|
|
|
|
|
|
|
|
|
|
| 221 |
if db_service:
|
| 222 |
-
|
|
|
|
| 223 |
logger.info("PostgreSQL bridge active.")
|
| 224 |
-
|
|
|
|
| 225 |
|
| 226 |
|
| 227 |
await mcp.initialize()
|
|
|
|
| 216 |
|
| 217 |
# --- Initialize MCP (registers tools, prepares SSE handler) ---
|
| 218 |
# db_sync only if cloud_DB used to!
|
|
|
|
| 219 |
# PSQL bridge — nur wenn Guardian DB-Service injiziert hat
|
| 220 |
+
# app.py — bridge-Block:
|
| 221 |
+
await db_sync.initialize()
|
| 222 |
+
|
| 223 |
if db_service:
|
| 224 |
+
# asyncpg Pool direkt nutzen — kein execute_secured_query nötig
|
| 225 |
+
db_sync.set_psql_writer(db_service.execute)
|
| 226 |
logger.info("PostgreSQL bridge active.")
|
| 227 |
+
else:
|
| 228 |
+
logger.info("PostgreSQL bridge inactive — no DATABASE_URL configured.")
|
| 229 |
|
| 230 |
|
| 231 |
await mcp.initialize()
|