From cea4633ceacaa7dc0f88cc53633a36ba45a460b4 Mon Sep 17 00:00:00 2001
From: MauricioGarciaS <47052044+MauricioGarciaS@users.noreply.github.com>
Date: Mon, 27 Nov 2023 16:41:43 +0100
Subject: [PATCH] Added exception in pool

---
 ee/connectors/utils/worker.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/ee/connectors/utils/worker.py b/ee/connectors/utils/worker.py
index a79e3dd3a..f3135e0fe 100644
--- a/ee/connectors/utils/worker.py
+++ b/ee/connectors/utils/worker.py
@@ -488,6 +488,12 @@ class WorkerPool:
                 except TimeoutError as e:
                     print('[WORKER-TimeoutError] Decoding of messages is taking longer than expected')
                     raise e
+                except Exception as e:
+                    print(f'[Exception] {e}')
+                    self.sessions_update_batch = dict()
+                    self.sessions_insert_batch = dict()
+                    self.events_batch = list()
+                    continue
             session_ids, messages = self._pool_response_handler(
                 pool_results=results)
             if current_loop_number == 0: