diff --git a/utils/fetch_pair_volatility.py b/utils/fetch_pair_volatility.py index 9dd0681..0b387a4 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"data/{broker}.db") + database_connection = sqlite3.connect(f"{get_credentials('VOL_DB_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]])