| | |
| | | |
| | | $op->errorMessage = $e->getMessage(); |
| | | |
| | | JVB()->error()->log( |
| | | '[Queue]:processOne', |
| | | $e->getMessage(), |
| | | [ |
| | | 'operation_id' => $op->id, |
| | | 'type' => $op->type, |
| | | 'user_id' => $op->userId, |
| | | 'retries' => $op->retries, |
| | | ], |
| | | $op->outcome === 'failed_permanent' ? 'critical' : 'warning' |
| | | ); |
| | | // JVB()->error()->log( |
| | | // '[Queue]:processOne', |
| | | // $e->getMessage(), |
| | | // [ |
| | | // 'operation_id' => $op->id, |
| | | // 'type' => $op->type, |
| | | // 'user_id' => $op->userId, |
| | | // 'retries' => $op->retries, |
| | | // ], |
| | | // $op->outcome === 'failed_permanent' ? 'critical' : 'warning' |
| | | // ); |
| | | } |
| | | |
| | | private function calculateBackoff(int $attempt): string |
| | |
| | | }; |
| | | } |
| | | |
| | | private function hasAdequateResources(): bool |
| | | public function hasAdequateResources(): bool |
| | | { |
| | | // Stricter thresholds for starting (50% memory, 60s minimum time) |
| | | $memoryLimit = $this->getMemoryLimitBytes(); |