notfire/Iceshrimp.NET
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[backend/queue] Fix jobs not being upserted with their correct default values

Browse source
This commit is contained in:
Laura Hausmann 2024-10-26 04:41:06 +02:00
parent e9d651b66f
commit effe3a7fef
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
Iceshrimp.Backend/Core/Services/QueueService.cs
View file

@ -531,7 +531,9 @@ public abstract class PostgresJobQueue<T>(
Id = Ulid.NewUlid().ToGuid(), Id = Ulid.NewUlid().ToGuid(),
Mutex = mutex, Mutex = mutex,
Queue = name, Queue = name,
Data = JsonSerializer.Serialize(jobData) Data = JsonSerializer.Serialize(jobData),
Status = Job.JobStatus.Queued,
QueuedAt = DateTime.UtcNow
}; };
await db.Jobs.Upsert(job).On(j => j.Mutex!).NoUpdate().RunAsync(); await db.Jobs.Upsert(job).On(j => j.Mutex!).NoUpdate().RunAsync();
@ -550,6 +552,7 @@ public abstract class PostgresJobQueue<T>(
Queue = name, Queue = name,
Data = JsonSerializer.Serialize(jobData), Data = JsonSerializer.Serialize(jobData),
Status = Job.JobStatus.Delayed, Status = Job.JobStatus.Delayed,
QueuedAt = DateTime.UtcNow,
DelayedUntil = triggerAt.ToUniversalTime() DelayedUntil = triggerAt.ToUniversalTime()
}; };