kin: KIN-OBS-020 Cleanup: import errno + двойной os.getpid() в agents/runner.py
This commit is contained in:
parent
8fa2cc266c
commit
da8110b2ea
1 changed files with 5 additions and 4 deletions
|
|
@ -663,6 +663,7 @@ def _migrate(conn: sqlite3.Connection):
|
||||||
# Fix orphaned dept_sub pipelines left in 'running' state due to double-create bug
|
# Fix orphaned dept_sub pipelines left in 'running' state due to double-create bug
|
||||||
# (KIN-ARCH-012): before the fix, _execute_department_head_step created a pipeline
|
# (KIN-ARCH-012): before the fix, _execute_department_head_step created a pipeline
|
||||||
# that was never updated, leaving ghost 'running' records in prod DB.
|
# that was never updated, leaving ghost 'running' records in prod DB.
|
||||||
|
if "pipelines" in existing_tables:
|
||||||
conn.execute(
|
conn.execute(
|
||||||
"UPDATE pipelines SET status = 'failed' WHERE route_type = 'dept_sub' AND status = 'running'"
|
"UPDATE pipelines SET status = 'failed' WHERE route_type = 'dept_sub' AND status = 'running'"
|
||||||
)
|
)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue