diff --git a/ee/connectors/utils/worker.py b/ee/connectors/utils/worker.py
index 164cebff7..2dafeeb5c 100644
--- a/ee/connectors/utils/worker.py
+++ b/ee/connectors/utils/worker.py
@@ -357,6 +357,7 @@ def fix_missing_redshift():
         database_api.pdredshift.exec_commit(base_query)
     except Exception as e:
         logging.error(f'[ERROR] Error while executing query. {repr(e)}')
+        logging.error(f'[ERROR INFO] query: {base_query}')
         database_api.close()
         asyncio.run(pg_client.terminate())
         return