use opensearch exception

pimcore · Dec 2, 2024 · 41f1bb7 · 41f1bb7
1 parent 6821a25
commit 41f1bb7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/IndexService/Worker/OpenSearch/AbstractOpenSearch.php b/src/IndexService/Worker/OpenSearch/AbstractOpenSearch.php
@@ -871,7 +871,7 @@ protected function getNextIndexVersion(): int
      * @param string $sourceIndexName the name of the source index in ES.
      * @param string $targetIndexName the name of the target index in ES. If existing, will be deleted
      *
-     * @throws \Exception
+     * @throws \OpenSearch\Common\Exceptions\OpenSearchException
      */
     protected function performReindex(string $sourceIndexName, string $targetIndexName): void
     {
@@ -926,7 +926,7 @@ protected function performReindex(string $sourceIndexName, string $targetIndexNa
         }
 
         if ($taskResponse === null || !isset($taskResponse['completed']) || $taskResponse['completed'] === false) {
-            throw new \Exception('reindex is not finished. Cleanup task index for task ' . $taskId);
+            throw new \OpenSearch\Common\Exceptions\RequestTimeout408Exception('reindex is not finished. Cleanup task index for task ' . $taskId);
         }
 
         Logger::info(sprintf('Completed re-index in %.02f seconds.', (time() - $startTime)));