diff --git a/utils/fetch_pair_volatility.py b/utils/fetch_pair_volatility.py
index 40f7955..7703112 100644
--- a/utils/fetch_pair_volatility.py
+++ b/utils/fetch_pair_volatility.py
@@ -8,6 +8,7 @@ import time
 import sqlite3
 import math
 import statistics
+import os
 from threading import Thread
 
 
@@ -156,7 +157,7 @@ if __name__=="__main__":
 
     #Create databases for each exchange
     for item in exchange_list:
-        database_connection = sqlite3.connect(f"data/{item}.db")
+        database_connection = sqlite3.connect(f"{os.environ['VOL_DB_PATH']}{item}.db")
         database_cursor = database_connection.cursor()           
         database_cursor.execute('''
             CREATE TABLE IF NOT EXISTS volatilities_table (