Fix: db.update_job fehlte im API-Modul (retry-transcode warf 500)
Ampel / ampel (push) Failing after 36s
Ampel / ampel (push) Failing after 36s
Die Job/Log-Tabellen leben bewusst doppelt in api/ und worker/ — update_job gab es nur im Worker. Der Import-Smoke-Test prueft Routen, aber keine Modul-Attribute; Lehre fuer die Etappe "geteiltes Paket". Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
@@ -154,6 +154,11 @@ def insert_job(
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def update_job(job_id: str, **fields) -> None:
|
||||||
|
with engine.begin() as conn:
|
||||||
|
conn.execute(jobs.update().where(jobs.c.id == job_id).values(**fields))
|
||||||
|
|
||||||
|
|
||||||
def get_job(job_id: str) -> dict:
|
def get_job(job_id: str) -> dict:
|
||||||
with engine.connect() as conn:
|
with engine.connect() as conn:
|
||||||
zeile = conn.execute(
|
zeile = conn.execute(
|
||||||
|
|||||||
Reference in New Issue
Block a user