From 4cef5a85245269cf2245b1bfdaf40e876fa368f9 Mon Sep 17 00:00:00 2001
From: MauricioGarciaS <47052044+MauricioGarciaS@users.noreply.github.com>
Date: Fri, 5 Jan 2024 16:48:11 +0100
Subject: [PATCH] fix(redshift-connector): Fixed close connection when
 exception

---
 ee/connectors/utils/worker.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ee/connectors/utils/worker.py b/ee/connectors/utils/worker.py
index f945c708f..38780f892 100644
--- a/ee/connectors/utils/worker.py
+++ b/ee/connectors/utils/worker.py
@@ -506,7 +506,7 @@ class WorkerPool:
             main_conn.send('CONTINUE')
         print('[WORKER-INFO] Sending close signal')
         main_conn.send('CLOSE')
-        self.terminate()
+        self.terminate(database_api)
         kafka_reader_process.terminate()
         print('[WORKER-SHUTDOWN] Process terminated')