diff --git a/apps/worker/worker.py b/apps/worker/worker.py index bfaa535..e9c66a0 100644 --- a/apps/worker/worker.py +++ b/apps/worker/worker.py @@ -268,9 +268,11 @@ def run_job(payload_dict: dict) -> dict: print(f"[{job_id}] Fetching STAC items for {payload['year']} {payload['season']}...") from stac_client import DEASTACClient - from config import InferenceConfig + from config import InferenceConfig, MinIOStorage as ConfigMinIO cfg = InferenceConfig() + # Initialize storage adapter for inference.py + cfg.storage = ConfigMinIO() # Get season dates start_date, end_date = cfg.season_dates(payload['year'], payload['season'])