Feat/ipman data vaib

implementations/manufacturing_stress_forecasting/README.md

@@ -0,0 +1,76 @@
+# Manufacturing stress forecasting — minimal IPMAN MVP
+
+This implementation asks one Track 1 question:
+
+> Given information available at a monthly forecast origin, what is the
+> probability that U.S. manufacturing will be under stress three months later?
+
+The model deliberately uses only five explanatory variables: trailing
+1-, 3-, and 6-month IPMAN changes, the effective federal funds rate, and the
+10-year minus 2-year Treasury yield spread. The small panel keeps the first
+multivariate experiment interpretable.
+
+## Target
+
+A month is labelled `1` (stress) when IPMAN has declined by at least 2% over
+its preceding three months; otherwise it is `0`. The threshold is a provisional
+version-1 definition and should be reviewed visually before expanding the
+project.
+
+The forecast made at month `t` predicts the stress label at `t + 3 months`.
+That distinction makes this forecasting rather than current-state detection.
+
+## Predictors
+
+- `HistoricalFrequencyPredictor`: the visible historical stress rate.
+- `ManufacturingStressLogisticPredictor`: fit-at-origin logistic regression on
+  the five IPMAN/rate variables.
+- `manufacturing_stress_analyst`: a structured LLM predictor receiving the same
+  five cutoff-safe signals plus recent IPMAN history and historical base rates.
+
+All predictors return `BinaryForecast` probabilities; backtested predictors are scored with Brier score.
+
+## Data and cutoff assumptions
+
+`FREDAdapter` caches `IPMAN`, `DFF`, `DGS10`, and `DGS2` under `data/fred/`.
+IPMAN is conservatively treated as available one month after its reference
+month. Daily rate observations are treated as available on the next business
+day and collapsed to their final monthly observation. The standard FRED API
+does not provide full point-in-time vintages, so historical observations may
+still contain later revisions; a production study should use ALFRED vintages.
+
+## Run
+
+From the repository root, put a personal FRED key in `.env` or export it:
+
+```bash
+export FRED_API_KEY="..."
+```
+
+Populate the cache and inspect the registered series:
+
+```bash
+uv run python scripts/fetch_manufacturing_stress.py
+```
+
+Run the small backtest:
+
+```bash
+uv run --directory implementations python -m manufacturing_stress_forecasting.run_smoke
+```
+
+The output prints one mean Brier score per predictor; lower is better. The
+logistic model should be compared against historical frequency, not judged in
+isolation.
+
+Run one current forecast, including the structured agent:
+
+```bash
+uv run --directory implementations python -m manufacturing_stress_forecasting.run_agent_prediction
+```
+
+## Next steps
+
+1. Plot IPMAN and the derived stress months; confirm or revise the 2% threshold.
+2. Compare the five-variable logistic score with the earlier IPMAN-only result.
+3. Backtest the agent only after the deterministic model is stable.

implementations/manufacturing_stress_forecasting/__init__.py

@@ -0,0 +1,16 @@
+"""Minimal IPMAN-based manufacturing-stress forecasting use case."""
+
+from manufacturing_stress_forecasting.data import (
+    IPMAN_SERIES_ID,
+    STRESS_SERIES_ID,
+    build_manufacturing_stress_service,
+)
+from manufacturing_stress_forecasting.predictors import ManufacturingStressLogisticPredictor
+
+
+__all__ = [
+    "IPMAN_SERIES_ID",
+    "STRESS_SERIES_ID",
+    "ManufacturingStressLogisticPredictor",
+    "build_manufacturing_stress_service",
+]

implementations/manufacturing_stress_forecasting/analyst_agent/__init__.py

@@ -0,0 +1,14 @@
+"""Quantitative-only manufacturing-stress analyst agent."""
+
+from manufacturing_stress_forecasting.analyst_agent.agent import (
+    ManufacturingStressPromptBuilder,
+    build_manufacturing_stress_agent_config,
+    build_manufacturing_stress_agent_predictor,
+)
+
+
+__all__ = [
+    "ManufacturingStressPromptBuilder",
+    "build_manufacturing_stress_agent_config",
+    "build_manufacturing_stress_agent_predictor",
+]

implementations/manufacturing_stress_forecasting/analyst_agent/agent.py

@@ -0,0 +1,163 @@
+"""Quantitative-only ADK agent for binary manufacturing-stress forecasts."""
+
+from __future__ import annotations
+
+import json
+from typing import Any
+
+import pandas as pd
+from aieng.forecasting.data.context import ForecastContext
+from aieng.forecasting.evaluation.task import ForecastingTask
+from aieng.forecasting.methods.agentic import (
+    AgentPredictor,
+    DiscreteAgentForecastOutput,
+    build_adk_agent,
+)
+from aieng.forecasting.methods.agentic.agent_factory import AgentConfig
+from aieng.forecasting.models import LITE_MODEL
+from manufacturing_stress_forecasting.data import IPMAN_SERIES_ID
+from manufacturing_stress_forecasting.features import (
+    FEATURE_SERIES_IDS,
+    IPMAN_FEATURE_SERIES_IDS,
+    MACRO_FEATURE_SERIES_IDS,
+    build_feature_snapshot,
+)
+from manufacturing_stress_forecasting.targets import (
+    DEFAULT_LOOKBACK_MONTHS,
+    DEFAULT_STRESS_THRESHOLD_PCT,
+)
+from pydantic import BaseModel, Field
+
+
+def _build_instruction() -> str:
+    schema = DiscreteAgentForecastOutput.prompt_schema_json()
+    return (
+        "## Role\n\n"
+        "You are a cautious U.S. manufacturing-cycle analyst. Estimate the probability that the "
+        "binary IPMAN stress event in the supplied task resolves to 1 at the specified forecast date.\n\n"
+        "## Rules\n\n"
+        "1. Use only the JSON payload. Do not use remembered events or facts after `as_of`.\n"
+        "2. Start from the supplied historical base rate, then adjust using the five supplied signals.\n"
+        "3. Treat negative IPMAN momentum, a restrictive fed funds rate, and an inverted 10Y-2Y spread "
+        "as possible evidence for stress; explain how the signals interact.\n"
+        "4. Do not double-count correlated signals or turn a weak signal into certainty.\n"
+        "5. `probability` means P(stress=1), not confidence in your explanation.\n"
+        "6. Give a concise rationale, identify both supporting and countervailing evidence, and remain calibrated.\n"
+        "7. Use `direction_bias='down'` when signals point toward manufacturing stress, `up` when they point "
+        "away from stress, and `neutral` when mixed.\n\n"
+        "## Output\n\n"
+        "Return exactly one JSON object matching this structure, with no markdown fence or preamble:\n\n" + schema
+    )
+
+
+class ManufacturingStressPromptBuilder(BaseModel):
+    """Serialize cutoff-safe IPMAN evidence into the agent's prompt."""
+
+    model_config = {"extra": "forbid"}
+
+    recent_history_months: int = Field(default=24, ge=6, le=120)
+    trailing_base_rate_months: int = Field(default=60, ge=12, le=240)
+
+    def __call__(self, *, task: ForecastingTask, context: ForecastContext) -> str:
+        """Build one structured, cutoff-safe forecast payload."""
+        if task.payload_type != "binary" or len(task.horizons) != 1:
+            raise ValueError("ManufacturingStressPromptBuilder requires one binary forecast horizon.")
+
+        as_of = pd.Timestamp(context.as_of)
+        offset = pd.tseries.frequencies.to_offset(task.frequency)
+        forecast_date = as_of + offset * task.horizons[0]
+        ipman = context.get_series(IPMAN_SERIES_ID).sort_values("timestamp")
+        target = context.get_series(task.target_series_id).sort_values("timestamp")
+        feature_frames = {series_id: context.get_series(series_id) for series_id in FEATURE_SERIES_IDS}
+        current_signals = build_feature_snapshot(as_of, feature_frames)
+        current_ipman_signals = (
+            {series_id: current_signals[series_id] for series_id in IPMAN_FEATURE_SERIES_IDS}
+            if current_signals is not None
+            else None
+        )
+        current_macro_signals = (
+            {series_id: current_signals[series_id] for series_id in MACRO_FEATURE_SERIES_IDS}
+            if current_signals is not None
+            else None
+        )
+
+        target_values = target["value"].astype(float)
+        trailing_values = target_values.tail(self.trailing_base_rate_months)
+        recent_ipman = [
+            {
+                "reference_month": str(pd.Timestamp(timestamp).date()),
+                "value": float(value),
+                "released_at": str(pd.Timestamp(released_at).date()),
+            }
+            for timestamp, value, released_at in zip(
+                ipman["timestamp"].tail(self.recent_history_months),
+                ipman["value"].tail(self.recent_history_months),
+                ipman["released_at"].tail(self.recent_history_months),
+                strict=True,
+            )
+        ]
+
+        payload: dict[str, Any] = {
+            "task": {
+                "task_id": task.task_id,
+                "question": task.description,
+                "horizon_months": task.horizons[0],
+            },
+            "as_of": str(as_of.date()),
+            "forecast_date": str(forecast_date.date()),
+            "target_definition": {
+                "event": "manufacturing stress",
+                "stress_value": 1,
+                "no_stress_value": 0,
+                "lookback_months": DEFAULT_LOOKBACK_MONTHS,
+                "threshold_pct": DEFAULT_STRESS_THRESHOLD_PCT,
+                "rule": ("stress=1 when trailing IPMAN percentage change is less than or equal to threshold_pct"),
+            },
+            "current_ipman_signals_pct": current_ipman_signals,
+            "current_macro_signals": current_macro_signals,
+            "historical_stress": {
+                "n_visible_months": len(target_values),
+                "all_history_base_rate": float(target_values.mean()) if len(target_values) else None,
+                "trailing_window_months": self.trailing_base_rate_months,
+                "trailing_base_rate": float(trailing_values.mean()) if len(trailing_values) else None,
+            },
+            "recent_ipman": recent_ipman,
+        }
+        return json.dumps(payload, indent=2)
+
+
+def build_manufacturing_stress_agent_config(model: str = LITE_MODEL) -> AgentConfig:
+    """Build the tool-free manufacturing analyst configuration."""
+    return AgentConfig(
+        name="manufacturing_stress_analyst",
+        model=model,
+        instruction=_build_instruction(),
+        temperature=0.1,
+        seed=42,
+        max_output_tokens=2_048,
+    )
+
+
+def build_manufacturing_stress_agent_predictor(
+    config: AgentConfig | None = None,
+) -> AgentPredictor:
+    """Wrap the analyst in the standard binary AgentPredictor contract."""
+    return AgentPredictor(
+        agent_config=config or build_manufacturing_stress_agent_config(),
+        prompt_builder=ManufacturingStressPromptBuilder(),
+        output_schema=DiscreteAgentForecastOutput,
+    )
+
+
+def __getattr__(name: str) -> Any:
+    """Expose a schema-free root agent for ``adk run`` and ``adk web``."""
+    if name == "root_agent":
+        return build_adk_agent(build_manufacturing_stress_agent_config())
+    raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
+
+
+__all__ = [
+    "ManufacturingStressPromptBuilder",
+    "build_manufacturing_stress_agent_config",
+    "build_manufacturing_stress_agent_predictor",
+]