rosslh/coolify
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(CleanupRedis): improve stuck job cleanup logic by prioritizing reserved_at timestamp

Browse source
This commit is contained in:
Andras Bacsai 2025-11-11 15:27:52 +01:00
parent 133d6a0349
commit 684a08bf75
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
app/Console/Commands/CleanupRedis.php
View file

@ -379,10 +379,19 @@ private function cleanupStuckJobs($redis, string $prefix, bool $dryRun, bool $is
// Parse job payload to get job class and started time // Parse job payload to get job class and started time
$payloadData = json_decode($payload, true); $payloadData = json_decode($payload, true);
$jobClass = data_get($payloadData, 'displayName', 'Unknown'); $jobClass = data_get($payloadData, 'displayName', 'Unknown');
$pushedAt = (int) data_get($data, 'pushed_at', 0);
// Prefer reserved_at (when job started processing), fallback to created_at
$reservedAt = (int) data_get($data, 'reserved_at', 0);
$createdAt = (int) data_get($data, 'created_at', 0);
$startTime = $reservedAt ?: $createdAt;
// If we can't determine when the job started, skip it
if (! $startTime) {
continue;
}
// Calculate how long the job has been processing // Calculate how long the job has been processing
$processingTime = $now - $pushedAt; $processingTime = $now - $startTime;
$shouldFail = false; $shouldFail = false;
$reason = ''; $reason = '';