From effe3a7fefe69ee532f49575f10e4dfc0614c6cc Mon Sep 17 00:00:00 2001 From: Laura Hausmann Date: Sat, 26 Oct 2024 04:41:06 +0200 Subject: [PATCH] [backend/queue] Fix jobs not being upserted with their correct default values --- Iceshrimp.Backend/Core/Services/QueueService.cs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/Iceshrimp.Backend/Core/Services/QueueService.cs b/Iceshrimp.Backend/Core/Services/QueueService.cs index fbe8c842..d323e815 100644 --- a/Iceshrimp.Backend/Core/Services/QueueService.cs +++ b/Iceshrimp.Backend/Core/Services/QueueService.cs @@ -528,10 +528,12 @@ public abstract class PostgresJobQueue( var job = new Job { - Id = Ulid.NewUlid().ToGuid(), - Mutex = mutex, - Queue = name, - Data = JsonSerializer.Serialize(jobData) + Id = Ulid.NewUlid().ToGuid(), + Mutex = mutex, + Queue = name, + Data = JsonSerializer.Serialize(jobData), + Status = Job.JobStatus.Queued, + QueuedAt = DateTime.UtcNow }; await db.Jobs.Upsert(job).On(j => j.Mutex!).NoUpdate().RunAsync(); @@ -550,6 +552,7 @@ public abstract class PostgresJobQueue( Queue = name, Data = JsonSerializer.Serialize(jobData), Status = Job.JobStatus.Delayed, + QueuedAt = DateTime.UtcNow, DelayedUntil = triggerAt.ToUniversalTime() };