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

Fixed param

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-22 00:38:16 +01:00
parent e9750292ba
commit c3a6de00e3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/py-metadata/worker/poller.py
View File

@ -28,7 +28,7 @@ def run_iteration(db: Database, worker_id: str, poll_interval: int) -> tuple[int
logger.info(f"🔔 Fant task {task.taskId} ({task.task}), claimed by {worker_id}") logger.info(f"🔔 Fant task {task.taskId} ({task.task}), claimed by {worker_id}")
try: try:
event: MetadataSearchResultEvent = asyncio.run(process_task(task)) event: MetadataSearchResultEvent = asyncio.run(process_task(db, task))
if event: if event:
persist_event_and_mark_consumed(db, event, str(task.taskId)) persist_event_and_mark_consumed(db, event, str(task.taskId))
logger.info(f"✅ Task {task.taskId} ferdig prosessert") logger.info(f"✅ Task {task.taskId} ferdig prosessert")