From b02e3baa64522ef451164d5df324ffdc67889361 Mon Sep 17 00:00:00 2001
From: JM Versteeg <5894809+sgtlambda@users.noreply.github.com>
Date: Wed, 4 Oct 2023 12:53:06 +0200
Subject: [PATCH] Update 2023_03_01_000000_update_queue_monitor_table.php

---
 .../2023_03_01_000000_update_queue_monitor_table.php   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/migrations/2023_03_01_000000_update_queue_monitor_table.php b/migrations/2023_03_01_000000_update_queue_monitor_table.php
index da399269..a1baae1a 100644
--- a/migrations/2023_03_01_000000_update_queue_monitor_table.php
+++ b/migrations/2023_03_01_000000_update_queue_monitor_table.php
@@ -1,12 +1,11 @@
 <?php
 
-use Illuminate\Database\Eloquent\Collection;
 use Illuminate\Database\Migrations\Migration;
 use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Collection;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Schema;
 use romanzipp\QueueMonitor\Enums\MonitorStatus;
-use romanzipp\QueueMonitor\Models\Monitor;
 
 class UpdateQueueMonitorTable extends Migration
 {
@@ -25,8 +24,9 @@ public function up()
 
     public function upgradeColumns()
     {
-        Monitor::query()->chunk(500, function (Collection $monitors) {
-            /** @var array<int, array<\romanzipp\QueueMonitor\Models\Monitor>> $matrix */
+        DB::table(config('queue-monitor.table'))->orderBy('id')->chunk(500, function (Collection $monitors) {
+
+            /** @var array<int, array<stdClass>> $matrix */
             $matrix = [
                 MonitorStatus::RUNNING => [],
                 MonitorStatus::FAILED => [],
@@ -46,7 +46,7 @@ public function upgradeColumns()
 
             foreach ($matrix as $status => $monitors) {
                 DB::table(config('queue-monitor.table'))
-                    ->whereIn('id', array_map(fn (Monitor $monitor) => $monitor->id, $monitors))
+                    ->whereIn('id', array_map(fn (stdClass $monitor) => $monitor->id, $monitors))
                     ->update(['status' => $status]);
             }
         });