diff --git a/daemon.py b/daemon.py
index e0940c2..ec5b6cc 100644
--- a/daemon.py
+++ b/daemon.py
@@ -52,7 +52,7 @@ def run_task(historical=False):
     
     db = DatabaseClient(host="questdb", user=DB_USER, password=DB_PASSWORD)
 
-    for exchange in exchanges:
+    for exchange, args in exchanges_to_process:
         try:
             db_url = "http://questdb:9000"
             last_ts = get_last_trade_timestamp(db_url, exchange.name)