fix: resolve NameError in run_task function

2026-01-23 18:00:34 +01:00
parent b0707443e8
commit 3fc149599e
1 changed files with 1 additions and 1 deletions
--- 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)