pelmen/kin
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: pelmen:9bd5c22cb5add0eee5f40a7491046d2c53647c78
Branches Tags
pelmen:main
..
compare: pelmen:8fa2cc266cf2670a6dbf85f9f4d11a0ac236a652
Branches Tags
pelmen:main

No commits in common. "9bd5c22cb5add0eee5f40a7491046d2c53647c78" and "8fa2cc266cf2670a6dbf85f9f4d11a0ac236a652" have entirely different histories.
9bd5c22cb5 ... 8fa2cc266c

2 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

1
core/db.py
View file

@ -663,7 +663,6 @@ 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'"
) )

3
tests/test_watchdog.py
View file

@ -1,7 +1,6 @@
"""Tests for pipeline watchdog (KIN-099, KIN-OBS-015, KIN-OBS-019).""" """Tests for pipeline watchdog (KIN-099, KIN-OBS-015)."""
import errno import errno
import inspect
import json import json
import os import os
import threading import threading