Lỗi như tiêu đề, bạn có thể xem tại https://github.com/laravel/framework/issues/15696
Và 1 lần nữa mấy anh contributors của laravel lại bảo đây là feature =))
https://github.com/laravel/framework/issues/15696#issuecomment-250935907
Tóm tắt lại là laravel sẽ chạy lại job sau khi job bị timeout bất kể bạn để try time bao nhiêu lần.
Đọc code của laravel bạn sẽ thấy. IlluminateQueueWorker::markJobAsFailedIfAlreadyExceedsMaxAttempts
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 | /** * Mark the given job as failed if it has exceeded the maximum allowed attempts. * * This will likely be because the job previously exceeded a timeout. * * @param string $connectionName * @param IlluminateContractsQueueJob $job * @param int $maxTries * @return void */ protected function markJobAsFailedIfAlreadyExceedsMaxAttempts($connectionName, $job, $maxTries) { $maxTries = ! is_null($job->maxTries()) ? $job->maxTries() : $maxTries; $timeoutAt = $job->timeoutAt(); if ($timeoutAt && Carbon::now()->getTimestamp() <= $timeoutAt) { return; } if (! $timeoutAt && ($maxTries === 0 || $job->attempts() <= $maxTries)) { return; } $this->failJob($connectionName, $job, $e = new MaxAttemptsExceededException( $job->resolveName().' has been attempted too many times or run too long. The job may have previously timed out.' )); throw $e; } |
Cách fix:
1. Set option retry_after và restart queue mỗi 1 khoảng thời gian < retry_after time
Ví dụ: Bạn set job retry_after bằng 3600 s và restart queue mỗi 2000s.
2. Chia nhỏ job thằng nhiều job con.
Nếu job của bạn đang thực hiện 1 công việc có thể chia nhỏ hơn, hay tạo ra job con và dispatch các job con trong job cha để tránh timeout.
3. Tạo 1 class extends từ class IlluminateQueueWorker và ghi đè funtion markJobAsFailedIfAlreadyExceedsMaxAttempts
Đơn giản là xóa 3 cái dòng của nợ kia đi.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 | /** * Mark the given job as failed if it has exceeded the maximum allowed attempts. * * This will likely be because the job previously exceeded a timeout. * * @param string $connectionName * @param IlluminateContractsQueueJob $job * @param int $maxTries * @return void */ protected function markJobAsFailedIfAlreadyExceedsMaxAttempts($connectionName, $job, $maxTries) { $maxTries = ! is_null($job->maxTries()) ? $job->maxTries() : $maxTries; $timeoutAt = $job->timeoutAt(); // if ($timeoutAt && Carbon::now()->getTimestamp() <= $timeoutAt) { // return; // } if (! $timeoutAt && ($maxTries === 0 || $job->attempts() <= $maxTries)) { return; } $this->failJob($connectionName, $job, $e = new MaxAttemptsExceededException( $job->resolveName().' has been attempted too many times or run too long. The job may have previously timed out.' )); throw $e; } |
Và đừng quên viết 1 console lệnh cho class worker mới nhé. Tham khảo code ở file vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php
Bạn nào viết xong chia sẻ lại cho mình nhé, mình chưa viết =))