Use configured chunk size and queue in ExportProcessor (#4)

CoreProc · Jul 25, 2024 · 04607b7 · 04607b7
1 parent ec11da5
commit 04607b7
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Export/Jobs/ExportProcessor.php b/src/Export/Jobs/ExportProcessor.php
@@ -39,7 +39,7 @@ public function formatRow($row): array
     public function handle(): void
     {
         $jobs = [];
-        $perPage = 500; // Number of items per page
+        $perPage = static::chunkSize(); // Number of items per page
         $totalRecords = $this->query()->count();
         $totalPages = ceil($totalRecords / $perPage);
         $batchUuid = Str::uuid();
@@ -83,9 +83,15 @@ public function handle(): void
             })
             ->allowFailures()
             ->name($this->name())
+            ->onQueue(config('nova-data-sync.exports.queue', 'default'))
             ->dispatch();
     }
 
+    public static function chunkSize(): int
+    {
+        return config('nova-data-sync.exports.chunk_size', 1000);
+    }
+
     protected function name(): string
     {
         if (empty($this->name)) {