From 76a5d155d797d5f49a7bc5e28a4783154424a079 Mon Sep 17 00:00:00 2001 From: fchinembiri Date: Fri, 1 May 2026 13:02:20 +0200 Subject: [PATCH] fix(worker): initialize cfg.storage in run_job for standard inference --- apps/worker/worker.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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'])