style(connectors): Added query log (#1409)

* style(connectors): Added query log * fix(connectors): changed info log to error log
2023-07-12 12:53:27 +02:00 · 2023-07-12 12:53:27 +02:00 · c9b4644350
commit c9b4644350
parent 0b95d26b40
1 changed files with 1 additions and 0 deletions
--- 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