iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Metadata app should not find other events

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-21 20:04:53 +01:00
parent 037525d8e3
commit d70238d3e0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/py-metadata/db/repository.py
View File

@ -11,7 +11,7 @@ def fetch_next_task(db: Database) -> Optional[Task]:
db.validate() db.validate()
cursor = db.conn.cursor(dictionary=True) cursor = db.conn.cursor(dictionary=True)
cursor.execute( 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" "ORDER BY PERSISTED_AT ASC LIMIT 1"
) )
row = cursor.fetchone() row = cursor.fetchone()
@ -23,7 +23,7 @@ def fetch_next_task(db: Database) -> Optional[Task]:
# hele JSON ligger i DATA # hele JSON ligger i DATA
return MetadataSearchTask.model_validate_json(row["DATA"]) return MetadataSearchTask.model_validate_json(row["DATA"])
else: else:
return Task.model_validate_json(row["DATA"]) return None
except Exception as e: except Exception as e:
logger.error(f"❌ Feil ved deserialisering av task {row.get('TASK_ID')}: {e}") logger.error(f"❌ Feil ved deserialisering av task {row.get('TASK_ID')}: {e}")
mark_failed(db, row["TASK_ID"]) mark_failed(db, row["TASK_ID"])