diff --git a/src/screener/t_sunnyband.py b/src/screener/t_sunnyband.py index d7ddb8d..130f1bb 100644 --- a/src/screener/t_sunnyband.py +++ b/src/screener/t_sunnyband.py @@ -25,16 +25,18 @@ def get_stock_data(ticker: str, start_date: datetime, end_date: datetime, interv # Unified query format query = f""" SELECT - date, + toDate(window_start) as date, open, high, low, close, volume - FROM stock_db.{table} + FROM stock_db.stock_prices WHERE ticker = '{ticker}' - AND date BETWEEN '{start_date.date()}' AND '{end_date.date()}' - ORDER BY date ASC + AND window_start BETWEEN + toUnixTimestamp('{start_date.date()}') * 1000000000 AND + toUnixTimestamp('{end_date.date()}') * 1000000000 + ORDER BY window_start ASC """ result = client.query(query)