| | |
| | | <?php |
| | | namespace JVBase\managers\queue; |
| | | use Throwable; |
| | | |
| | | if (!defined('ABSPATH')) { |
| | | exit; |
| | | } |
| | |
| | | $op->result = $result->result; |
| | | $op->completedAt = current_time('mysql'); |
| | | |
| | | } catch (\Throwable $e) { |
| | | } catch (Throwable $e) { |
| | | error_log("[Processor] Exception caught: " . $e->getMessage()); |
| | | $this->handleFailure($op, $e); |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | } catch (\Throwable $e) { |
| | | } catch (Throwable $e) { |
| | | error_log("[Processor] Chunk {$index} failed: " . $e->getMessage()); |
| | | |
| | | // Record failed items from this chunk |
| | |
| | | return $chunks; |
| | | } |
| | | |
| | | private function handleFailure(Operation $op, \Throwable $e): void |
| | | private function handleFailure(Operation $op, Throwable $e): void |
| | | { |
| | | $hash = md5($e->getMessage()); |
| | | |