Update 2023_03_01_000000_update_queue_monitor_table.php

romanzipp · Oct 4, 2023 · b02e3ba · b02e3ba
1 parent 6a9a557
commit b02e3ba
Showing 1 changed file with 5 additions and 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
@@ -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]);
             }
         });