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

[backend/queue] Improve logging

Browse source
This commit is contained in:
Laura Hausmann 2024-04-15 18:00:11 +02:00
parent 8fb7c8a93e
commit c25b613376
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -265,8 +265,9 @@ public class PostgresJobQueue<T>(
{ {
if (!token.IsCancellationRequested) if (!token.IsCancellationRequested)
{ {
logger.LogError("ExecuteAsync in queue {queue} failed with: {error}", name, e.Message); logger.LogError("ExecuteAsync for queue {queue} failed with: {error}", name, e);
await Task.Delay(1000, token); await Task.Delay(1000, token);
logger.LogDebug("Restarting ExecuteAsync worker for queue {queue}", name);
} }
} }
} }
@ -347,8 +348,9 @@ public class PostgresJobQueue<T>(
{ {
if (!token.IsCancellationRequested) if (!token.IsCancellationRequested)
{ {
logger.LogError("DelayedJobHandlerAsync in queue {queue} failed with: {error}", name, e.Message); logger.LogError("DelayedJobHandlerAsync for queue {queue} failed with: {error}", name, e);
await Task.Delay(1000, token); await Task.Delay(1000, token);
logger.LogDebug("Restarting DelayedJobHandlerAsync worker for queue {queue}", name);
} }
} }
} }
@ -396,7 +398,9 @@ public class PostgresJobQueue<T>(
catch (Exception e) catch (Exception e)
{ {
var logger = scope.ServiceProvider.GetRequiredService<ILogger<QueueService>>(); var logger = scope.ServiceProvider.GetRequiredService<ILogger<QueueService>>();
logger.LogError("ProcessJobAsync failed with: {e}", e.Message); logger.LogError("ProcessJobAsync for queue {queue} failed with: {error}", name, e);
logger.LogError("Queue worker(s) for queue {queue} might be degraded or stalled. Please report this bug to the developers.",
name);
} }
} }