From dc66e80a93b34ccd720e2fbfbd503588d207c459 Mon Sep 17 00:00:00 2001
From: aynsix <asr@esokia-webagency.com>
Date: Thu, 6 Aug 2020 11:16:53 +0300
Subject: [PATCH] reconnect if connection closed

---
 .../Phrasea/WorkerManager/Worker/PopulateIndexWorker.php        | 2 ++
 1 file changed, 2 insertions(+)

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'))