fix(worker): initialize cfg.storage in run_job for standard inference
Build and Push Docker Images / build-and-push (push) Successful in 16m44s Details

This commit is contained in:
fchinembiri 2026-05-01 13:02:20 +02:00
parent bcba162afd
commit 76a5d155d7
1 changed files with 3 additions and 1 deletions

View File

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