From 9facfaeab622d9e536bf87ba5920b11967549e24 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nicol=C3=A1s=20S=C3=A1nchez?= Date: Tue, 5 Nov 2024 20:02:14 -0300 Subject: [PATCH] write_to_db bug --- utils/fetch_pair_volatility.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/utils/fetch_pair_volatility.py b/utils/fetch_pair_volatility.py index 0b387a4..e89dc38 100644 --- a/utils/fetch_pair_volatility.py +++ b/utils/fetch_pair_volatility.py @@ -64,7 +64,7 @@ def write_to_db(broker,data): Write data to database """ - database_connection = sqlite3.connect(f"{get_credentials('VOL_DB_PATH')}{broker}.db") + database_connection = sqlite3.connect(f"{get_credentials('VOL_DB_PATH')['path']}{broker}.db") database_cursor = database_connection.cursor() for item in data: database_cursor.execute('INSERT INTO volatilities_table VALUES(?, ?, ?, ?, ?)', [item, int(time.time()), data[item][0], data[item][1], data[item][2]]) @@ -157,7 +157,7 @@ if __name__=="__main__": #Create databases for each exchange for item in exchange_list: - database_connection = sqlite3.connect(f"{get_credentials('VOL_DB_PATH')}{item}.db") + database_connection = sqlite3.connect(f"{get_credentials('VOL_DB_PATH')['path']}{item}.db") database_cursor = database_connection.cursor() database_cursor.execute(''' CREATE TABLE IF NOT EXISTS volatilities_table (