jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(redshift-connector): Fixed close connection when exception

Browse source
This commit is contained in:
MauricioGarciaS 2024-01-05 16:48:11 +01:00
parent d3a611a676
commit 4cef5a8524
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ee/connectors/utils/worker.py
View file

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