diff --git a/lib/Alchemy/Phrasea/WorkerManager/Worker/PopulateIndexWorker.php b/lib/Alchemy/Phrasea/WorkerManager/Worker/PopulateIndexWorker.php index f10f6d12af..daacda5f8a 100644 --- a/lib/Alchemy/Phrasea/WorkerManager/Worker/PopulateIndexWorker.php +++ b/lib/Alchemy/Phrasea/WorkerManager/Worker/PopulateIndexWorker.php @@ -36,6 +36,7 @@ class PopulateIndexWorker implements WorkerInterface public function process(array $payload) { $em = $this->repoWorker->getEntityManager(); + $this->repoWorker->reconnect(); if (isset($payload['workerJobId'])) { /** @var WorkerRunningJob $workerRunningJob */ @@ -139,6 +140,7 @@ class PopulateIndexWorker implements WorkerInterface // tell that the populate is finished if ($workerRunningJob != null) { + $this->repoWorker->reconnect(); $workerRunningJob ->setStatus(WorkerRunningJob::FINISHED) ->setFinished(new \DateTime('now'))