Adjustments

This commit is contained in:
Brage Skjønborg 2026-01-18 19:29:36 +01:00
parent 93de9b4497
commit 4a06a108a9
2 changed files with 13 additions and 4 deletions

View File

@ -22,7 +22,7 @@ async def health():
db_error = None db_error = None
worker_error = None worker_error = None
# Sjekk database # --- Database check ---
try: try:
db.ping() db.ping()
db_ok = True db_ok = True
@ -30,10 +30,18 @@ async def health():
db_ok = False db_ok = False
db_error = str(e) db_error = str(e)
# Sjekk worker heartbeat # --- Worker heartbeat check ---
try: try:
last = get_worker_heartbeat() last = get_worker_heartbeat()
worker_ok = (time.time() - last) < 10 now = time.time()
diff = now - last
worker_ok = diff < 10
# Hvis worker er false og ingen exception ble kastet → legg diff i worker_error
if not worker_ok and worker_error is None:
worker_error = f"Heartbeat too old: {diff:.2f}s"
except Exception as e: except Exception as e:
worker_ok = False worker_ok = False
worker_error = str(e) worker_error = str(e)

View File

@ -34,7 +34,8 @@ def get_heartbeat():
async def run_worker(db: Database, paths, extensions, shutdown_flag_ref): async def run_worker(db: Database, paths, extensions, shutdown_flag_ref):
global observers global observers
observers = [start_observer(db, [p], extensions, insert_event) for p in paths] observers = [start_observer(db, p, extensions, insert_event) for p in paths]
try: try:
while not shutdown_flag_ref(): while not shutdown_flag_ref():