From d70238d3e0b2a220d6dea78a930b5ca090198978 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= Date: Wed, 21 Jan 2026 20:04:53 +0100 Subject: [PATCH] Metadata app should not find other events --- apps/py-metadata/db/repository.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/py-metadata/db/repository.py b/apps/py-metadata/db/repository.py index d99b1afb..3ada669b 100644 --- a/apps/py-metadata/db/repository.py +++ b/apps/py-metadata/db/repository.py @@ -11,7 +11,7 @@ def fetch_next_task(db: Database) -> Optional[Task]: db.validate() cursor = db.conn.cursor(dictionary=True) cursor.execute( - "SELECT * FROM TASKS WHERE STATUS='Pending' AND CLAIMED=0 AND CONSUMED=0 " + "SELECT * FROM TASKS WHERE TASK='MetadataSearchTask' AND STATUS='Pending' AND CLAIMED=0 AND CONSUMED=0 " "ORDER BY PERSISTED_AT ASC LIMIT 1" ) row = cursor.fetchone() @@ -23,7 +23,7 @@ def fetch_next_task(db: Database) -> Optional[Task]: # hele JSON ligger i DATA return MetadataSearchTask.model_validate_json(row["DATA"]) else: - return Task.model_validate_json(row["DATA"]) + return None except Exception as e: logger.error(f"❌ Feil ved deserialisering av task {row.get('TASK_ID')}: {e}") mark_failed(db, row["TASK_ID"])