fix(api): skip bootstrap ddl statement timeout

apps/api/tests/test_runtime_bootstrap_guards.py

@@ -12,6 +12,7 @@ from collections.abc import Awaitable
 from typing import Any
 
 import pytest
+from sqlalchemy.exc import DBAPIError
 
 
 class _FakeScalarResult:
@@ -190,6 +191,29 @@ async def test_init_db_releases_bootstrap_lock_when_ddl_times_out(monkeypatch):
     assert any("pg_advisory_unlock" in stmt for stmt in fake_engine.lock_conn.statements)
 
 
+@pytest.mark.asyncio
+async def test_init_db_skips_bootstrap_when_postgres_statement_timeout(monkeypatch):
+    from src.db import base as db_base
+
+    fake_engine = _FakeEngine()
+
+    async def fake_run_init_db_ddl(_engine: object) -> None:
+        raise DBAPIError(
+            "ALTER TABLE approval_records ADD COLUMN IF NOT EXISTS telegram_message_id",
+            {},
+            Exception("canceling statement due to statement timeout"),
+        )
+
+    monkeypatch.setattr(db_base, "get_engine", lambda: fake_engine)
+    monkeypatch.setattr(db_base, "_run_init_db_ddl", fake_run_init_db_ddl)
+
+    await db_base.init_db()
+
+    assert "pg_try_advisory_lock" in fake_engine.lock_conn.statements[0]
+    assert any("pg_advisory_unlock" in stmt for stmt in fake_engine.lock_conn.statements)
+    assert "COMMIT" in fake_engine.lock_conn.statements
+
+
 @pytest.mark.asyncio
 async def test_signal_worker_initializes_worker_redis_pool_before_tasks(monkeypatch):
     from src.workers import signal_worker