treehouselabs /
worker-bundle
| @@ 118-126 (lines=9) @@ | ||
| 115 | $this->logJob($job->getId(), $e->getTraceAsString(), LogLevel::DEBUG, $context); |
|
| 116 | ||
| 117 | // see if we have any retries left |
|
| 118 | if ($releases > $maxRetries) { |
|
| 119 | // no more retries, bury job for manual inspection |
|
| 120 | $this->queue->bury($job); |
|
| 121 | ||
| 122 | $this->dispatcher->dispatch(WorkerEvents::JOB_BURIED_EVENT, new JobBuriedEvent($job, $e, $releases)); |
|
| 123 | } else { |
|
| 124 | // try again, regardless of the error |
|
| 125 | $this->queue->reschedule($job, new \DateTime('+10 minutes'), $priority); |
|
| 126 | } |
|
| 127 | } |
|
| 128 | ||
| 129 | return false; |
|
| @@ 527-535 (lines=9) @@ | ||
| 524 | $this->logJob($job->getId(), $e->getTraceAsString(), LogLevel::DEBUG, $context); |
|
| 525 | ||
| 526 | // see if we have any retries left |
|
| 527 | if ($releases > $maxRetries) { |
|
| 528 | // no more retries, bury job for manual inspection |
|
| 529 | $this->bury($job); |
|
| 530 | ||
| 531 | $this->dispatcher->dispatch(WorkerEvents::JOB_BURIED_EVENT, new JobBuriedEvent($job, $e, $releases)); |
|
| 532 | } else { |
|
| 533 | // try again, regardless of the error |
|
| 534 | $this->reschedule($job, new \DateTime('+10 minutes'), $priority); |
|
| 535 | } |
|
| 536 | } |
|
| 537 | ||
| 538 | return false; |
|
