from public_data_ingest import fetch_macro_anchor from economic_kernel import economic_kernel from logistics_engine import logistics_kernel from energy_engine import energy_kernel from sentiment_engine import sentiment_kernel from analytics_engine import analytics_kernel def run_engine(commodity, anchor, lag_days): macro = fetch_macro_anchor() econ = economic_kernel( commodity=commodity, anchor=anchor, macro=macro ) logistics = logistics_kernel(econ) energy = energy_kernel(econ) sentiment = sentiment_kernel(commodity) return { "macro_anchor": macro, "commodity": commodity, "economic_state": econ, "logistics": logistics, "energy": energy, "sentiment": sentiment, "projection": analytics_kernel( econ, logistics, energy, sentiment, lag_days ) }