didericis-claude
1f192d785a
test / stage-firecracker-inputs (push) Successful in 2s
test / integration-docker (push) Successful in 17s
Update Quality Badges / update-badges (push) Failing after 42s
lint / lint (push) Successful in 47s
test / unit (push) Successful in 1m41s
test / build-infra (push) Successful in 3m43s
test / integration-firecracker (push) Successful in 1m28s
test / coverage (push) Successful in 1m29s
test / publish-infra (push) Successful in 1m49s
Switch orchestrator_config from a generic key/text store to a typed single-row table with a dedicated teardown_timeout_seconds REAL column. The CHECK (id = 1) constraint enforces at most one config row. Remove TEARDOWN_TIMEOUT_KEY constant; update OrchestratorConfigStore to expose get/set/delete_teardown_timeout_seconds() instead of the generic get/set/delete(key). Resolving the DB value in resolve_teardown_timeout() no longer needs a float() conversion since the column is already REAL.
108 lines
3.4 KiB
Python
108 lines
3.4 KiB
Python
"""Per-host orchestrator configuration store (settings in bot-bottle.db).
|
|
|
|
Co-tenants the shared `bot-bottle.db` via the `DbStore` framework. Settings
|
|
are readable by the host launch path directly (no HTTP round-trip to the
|
|
orchestrator), so they take effect even before the orchestrator is reachable.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import os
|
|
import sqlite3
|
|
from pathlib import Path
|
|
|
|
from ..db_store import DbStore
|
|
from ..migrations import TableMigrations
|
|
from ..paths import host_db_path
|
|
|
|
TEARDOWN_TIMEOUT_ENV = "BOT_BOTTLE_ORCHESTRATOR_TEARDOWN_TIMEOUT_SECONDS"
|
|
DEFAULT_TEARDOWN_TIMEOUT_SECONDS = 30.0
|
|
|
|
_MIGRATIONS = TableMigrations(
|
|
"orchestrator_config",
|
|
[
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS orchestrator_config (
|
|
id INTEGER PRIMARY KEY CHECK (id = 1),
|
|
teardown_timeout_seconds REAL
|
|
)
|
|
""",
|
|
],
|
|
)
|
|
|
|
|
|
class OrchestratorConfigStore(DbStore):
|
|
"""Orchestrator settings in the shared host DB."""
|
|
|
|
def __init__(self, db_path: Path | None = None) -> None:
|
|
super().__init__(db_path or host_db_path(), _MIGRATIONS)
|
|
|
|
def _connect(self) -> sqlite3.Connection:
|
|
conn = super()._connect()
|
|
conn.execute("PRAGMA busy_timeout=5000")
|
|
return conn
|
|
|
|
def get_teardown_timeout_seconds(self) -> float | None:
|
|
"""Return the configured teardown timeout, or None if not set."""
|
|
try:
|
|
with self._connection() as conn:
|
|
row = conn.execute(
|
|
"SELECT teardown_timeout_seconds FROM orchestrator_config WHERE id = 1"
|
|
).fetchone()
|
|
except sqlite3.OperationalError:
|
|
return None
|
|
return row["teardown_timeout_seconds"] if row else None
|
|
|
|
def set_teardown_timeout_seconds(self, value: float) -> None:
|
|
"""Persist the teardown timeout."""
|
|
with self._connection() as conn:
|
|
conn.execute(
|
|
"INSERT OR REPLACE INTO orchestrator_config"
|
|
" (id, teardown_timeout_seconds) VALUES (1, ?)",
|
|
(value,),
|
|
)
|
|
self._chmod()
|
|
|
|
def delete_teardown_timeout_seconds(self) -> bool:
|
|
"""Clear the stored teardown timeout. Returns True if a value existed."""
|
|
with self._connection() as conn:
|
|
cur = conn.execute(
|
|
"UPDATE orchestrator_config SET teardown_timeout_seconds = NULL"
|
|
" WHERE id = 1 AND teardown_timeout_seconds IS NOT NULL"
|
|
)
|
|
return cur.rowcount > 0
|
|
|
|
|
|
def resolve_teardown_timeout(db_path: Path | None = None) -> float:
|
|
"""Return the teardown timeout to use, in priority order:
|
|
|
|
1. ``BOT_BOTTLE_ORCHESTRATOR_TEARDOWN_TIMEOUT_SECONDS`` env var
|
|
2. ``teardown_timeout_seconds`` in the orchestrator config DB
|
|
3. ``DEFAULT_TEARDOWN_TIMEOUT_SECONDS`` (30 s)
|
|
"""
|
|
raw = os.environ.get(TEARDOWN_TIMEOUT_ENV, "").strip()
|
|
if raw:
|
|
try:
|
|
value = float(raw)
|
|
if value > 0:
|
|
return value
|
|
except ValueError:
|
|
pass
|
|
|
|
store = OrchestratorConfigStore(db_path)
|
|
if not store.is_migrated():
|
|
store.migrate()
|
|
db_value = store.get_teardown_timeout_seconds()
|
|
if db_value is not None and db_value > 0:
|
|
return db_value
|
|
|
|
return DEFAULT_TEARDOWN_TIMEOUT_SECONDS
|
|
|
|
|
|
__all__ = [
|
|
"OrchestratorConfigStore",
|
|
"resolve_teardown_timeout",
|
|
"TEARDOWN_TIMEOUT_ENV",
|
|
"DEFAULT_TEARDOWN_TIMEOUT_SECONDS",
|
|
]
|