diff --git a/backend/src/backup_tool/execution.py b/backend/src/backup_tool/execution.py index 582ca6d..7dd2d42 100644 --- a/backend/src/backup_tool/execution.py +++ b/backend/src/backup_tool/execution.py @@ -54,6 +54,8 @@ async def enqueue(db: AsyncSession, job_id: str, trigger: str = "manual") -> Exe job_identifier = job.id execution = Execution(job_id=job_identifier, trigger=trigger, progress={}) db.add(execution) + await db.flush() + await record_event(db, execution) try: await db.commit() except IntegrityError as error: