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 (