UHF-10581: add reindex exception

City-of-Helsinki · Oct 7, 2024 · e6fe136 · e6fe136
1 parent e7fd339
commit e6fe136
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/public/modules/custom/helfi_google_api/src/Plugin/QueueWorker/IndexingWorker.php b/public/modules/custom/helfi_google_api/src/Plugin/QueueWorker/IndexingWorker.php
@@ -7,6 +7,7 @@
 use Drupal\Core\Entity\EntityTypeManagerInterface;
 use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
 use Drupal\Core\Queue\QueueWorkerBase;
+use Drupal\Core\Queue\RequeueException;
 use Drupal\helfi_google_api\JobIndexingService;
 use Drupal\helfi_rekry_content\Entity\JobListing;
 use Symfony\Component\DependencyInjection\ContainerInterface;
@@ -63,7 +64,7 @@ public static function create(ContainerInterface $container, array $configuratio
  * {@inheritdoc}
  */
  public function processItem($data): void {
- if (!$data['nid']) {
+ if (!isset($data['nid'])) {
  return;
  }
 
@@ -75,10 +76,10 @@ public function processItem($data): void {
  }
 
  try {
- $this->jobIndexingService->indexEntity($node);
+ $result = $this->jobIndexingService->indexEntity($node);
  }
  catch (\Exception $e) {
- // Handled in service.
+ throw new RequeueException();
  }
  }