@@ -318,7 +318,7 @@ def plot_forecast(self, ticker: str = None, lowq: int = 0.2):
318
318
self .canswim_model .train_history
319
319
)
320
320
visible_target = target .drop_before (plot_start_date )
321
- saved_forecast_df_list = self .get_saved_forecasts (ticker = ticker )
321
+ saved_forecast_df_list = self .get_saved_forecasts (ticker = ticker , start_date = plot_start_date )
322
322
lq = (100 - lowq ) / 100
323
323
visible_target .plot (label = f"{ ticker } Close actual" )
324
324
# logger.debug(f"Plotting saved forecast: {saved_forecast_df_list}")
@@ -352,19 +352,19 @@ def plot_forecast(self, ticker: str = None, lowq: int = 0.2):
352
352
plt .legend ()
353
353
return {self .plotComponent : fig , self .rrTable : rr_df }
354
354
355
- def get_saved_forecasts (self , ticker : str = None ):
355
+ def get_saved_forecasts (self , ticker : str = None , start_date = None ):
356
356
"""Load forecasts from storage to a list of individual forecast series with quantile sampling"""
357
357
# load parquet partition for stock
358
- logger .info (f"Loading saved forecast for { ticker } " )
358
+ logger .info (f"Loading saved forecast for { ticker } starting after: { start_date } " )
359
359
with duckdb .connect (self .db_path ) as db_con :
360
360
sql_result = db_con .sql (
361
361
f"""--sql
362
362
SELECT *
363
363
FROM forecast as f
364
- WHERE f.symbol = $ticker
364
+ WHERE f.symbol = $ticker AND f.start_date >= $start_date
365
365
ORDER BY f.symbol, f.start_date, f.date
366
366
""" ,
367
- params = {"ticker" : ticker },
367
+ params = {"ticker" : ticker , "start_date" : start_date },
368
368
)
369
369
df = sql_result .df ()
370
370
# filters = [("symbol", "=", ticker)]
0 commit comments