src/inference.py

from .signal_ingestor import SignalIngestor
from .feature_engineer import FeatureEngineer
from .trend_model import TrendModel
from .forecaster import Forecaster

class FutureTrendPipeline:
    def __init__(self):
        self.i=SignalIngestor(); self.f=FeatureEngineer(); self.m=TrendModel(); self.o=Forecaster()
    def __call__(self,path,horizon=6):
        r=self.i.load_csv(path); feats=self.f.build_features(r)
        preds=self.m.predict(feats,horizon)
        return self.o.forecast(preds)