market_pulse

1-minute market-pulse arena. Pulls live OHLC + indicators + news from trtools2 streams, fans the question across three specialists (price action, news, volatility regime), synthesises a verdict, and — crucially — a ReplanAgent decides whether confidence is high enough to commit, or whether to enable additional sources (macro context, knowledge graph, deep data request to fomo2) and re-run. The committed verdict is published as a structured TradingAction on ``maf:actions:out``; trtools2 picks it up and executes / queues / logs per the action's ``mode`` field. Trigger via control plane: XADD maf:control:in '*' data '{ "command": "run_arena", "args": { "arena": "market_pulse", "target": {"ticker": "SPY", "context_tickers": ["VIX"]}, "action_mode": "semi" } }'

manual

Phase Pipeline

analysis

parallel

price_analyst (3 tools)

news_analyst (1 tools)

vol_regime_analyst (2 tools)

kronos_specialist (1 tools)

→

synthesis

sequential

synthesis_agent

→

replan_check

sequential

replan_controller

→

emit

sequential

Ticker

Date

Configure the arena's metadata, data sources, agents and phases. Changes write to the YAML file. Restart the app to apply.

Metadata

Description One-line summary shown on the dashboard. Schedule Cron expression. Leave blank for manual-only runs. Max iterations How many replan loops are allowed before giving up. Target key Drives which outbox publishes the verdict.

Data sources

Bind data adapters to symbolic names. Agents reference these names in their sources list.

Agents

Each agent runs a ReAct loop, calls its bound sources as tools, and emits a structured signal.

Phases

Phases run in order. parallel fans out specialists, sequential runs one-by-one, debate does N-way rounds + judge.

Smart triggers

Auto-run this arena when a Redis Stream event matches a rule. Rules run through safe_eval (boolean/comparisons, abs(), payload.field). Reference →

Ticker

Start Date

End Date

Edit arena configuration (JSON). Changes write to YAML file — restart to apply.

{
  "applicable_target_types": [],
  "description": "1-minute market-pulse arena. Pulls live OHLC + indicators + news from\ntrtools2 streams, fans the question across three specialists (price action,\nnews, volatility regime), synthesises a verdict, and \u2014 crucially \u2014 a\nReplanAgent decides whether confidence is high enough to commit, or\nwhether to enable additional sources (macro context, knowledge graph, deep\ndata request to fomo2) and re-run. The committed verdict is published as\na structured TradingAction on ``maf:actions:out``; trtools2 picks it up and\nexecutes / queues / logs per the action\u0027s ``mode`` field.\n\nTrigger via control plane:\n  XADD maf:control:in \u0027*\u0027 data \u0027{\n    \"command\": \"run_arena\",\n    \"args\": {\n      \"arena\": \"market_pulse\",\n      \"target\": {\"ticker\": \"SPY\", \"context_tickers\": [\"VIX\"]},\n      \"action_mode\": \"semi\"\n    }\n  }\u0027\n",
  "llm": {
    "deep_model": "auto",
    "deep_provider": "ollama",
    "default_provider": "ollama",
    "providers": {
      "ollama": {
        "api_key": "529224e623bb4df6bd2d35ca70830b11.1OcHilLKpOBPZbD1VizrA21P",
        "base_url": "https://ollama.com/v1",
        "max_output_tokens": 4096,
        "model": "auto",
        "temperature": 0.2
      }
    },
    "quick_model": "auto",
    "quick_provider": "ollama"
  },
  "max_iterations": 3,
  "memory": {
    "chromadb_path": "./data/chromadb",
    "embedding_model": "text-embedding-004",
    "embedding_provider": "gemini",
    "instances": [
      {
        "name": "synthesis_bm25",
        "persist_path": "",
        "type": "bm25"
      }
    ]
  },
  "name": "market_pulse",
  "output_stream": "maf:arena:market_pulse:output",
  "phases": [
    {
      "agents": [
        {
          "applicable_target_types": [],
          "extra": {},
          "llm_tier": "quick",
          "max_react_steps": 5,
          "name": "price_analyst",
          "role": "specialist",
          "sources": [
            "bars_1m_target",
            "indicators_target",
            "strategy_events"
          ],
          "system_prompt": "",
          "system_prompt_file": "src/maf/arenas/trading_intelligence/prompts/price_analyst.txt",
          "tools": []
        },
        {
          "applicable_target_types": [],
          "extra": {},
          "llm_tier": "quick",
          "max_react_steps": 5,
          "name": "news_analyst",
          "role": "specialist",
          "sources": [
            "news_recent"
          ],
          "system_prompt": "",
          "system_prompt_file": "src/maf/arenas/trading_intelligence/prompts/news_analyst.txt",
          "tools": []
        },
        {
          "applicable_target_types": [],
          "extra": {},
          "llm_tier": "quick",
          "max_react_steps": 5,
          "name": "vol_regime_analyst",
          "role": "specialist",
          "sources": [
            "bars_1m_vix",
            "indicators_target"
          ],
          "system_prompt": "",
          "system_prompt_file": "src/maf/arenas/trading_intelligence/prompts/vol_regime_analyst.txt",
          "tools": []
        },
        {
          "applicable_target_types": [],
          "extra": {},
          "llm_tier": "quick",
          "max_react_steps": 2,
          "name": "kronos_specialist",
          "role": "specialist",
          "sources": [
            "kronos_forecast_1m"
          ],
          "system_prompt": "",
          "system_prompt_file": "src/maf/arenas/trading_intelligence/prompts/kronos_specialist.txt",
          "tools": []
        }
      ],
      "max_rounds": 1,
      "name": "analysis",
      "pattern": "parallel",
      "signal_extract": false,
      "transition": "synthesis"
    },
    {
      "agents": [
        {
          "applicable_target_types": [],
          "extra": {},
          "llm_tier": "deep",
          "max_react_steps": 5,
          "memory": "synthesis_bm25",
          "name": "synthesis_agent",
          "role": "synthesis",
          "sources": [],
          "system_prompt": "",
          "system_prompt_file": "src/maf/arenas/trading_intelligence/prompts/synthesis_agent.txt",
          "tools": []
        }
      ],
      "max_rounds": 1,
      "name": "synthesis",
      "pattern": "sequential",
      "signal_extract": false,
      "transition": "replan_check"
    },
    {
      "agents": [
        {
          "applicable_target_types": [],
          "extra": {
            "available_sources": [
              "fomo2_deep_news",
              "fomo2_knowledge",
              "macro_context",
              "enriched_items",
              "kronos_forecast_1m"
            ],
            "confidence_floor": 0.7,
            "loopback_phase": "analysis"
          },
          "llm_tier": "deep",
          "max_react_steps": 5,
          "name": "replan_controller",
          "role": "replan",
          "sources": [],
          "system_prompt": "",
          "tools": []
        }
      ],
      "max_rounds": 1,
      "name": "replan_check",
      "pattern": "sequential",
      "signal_extract": false,
      "transition": "emit"
    },
    {
      "agents": [],
      "max_rounds": 1,
      "name": "emit",
      "pattern": "sequential",
      "signal_extract": false,
      "transition": "END"
    }
  ],
  "sources": [
    {
      "adapter": "trtools2_bars",
      "applicable_target_types": [],
      "config": {
        "count": 60,
        "stream": "trtools2:bars:1m",
        "timeframe": "1m"
      },
      "name": "bars_1m_target"
    },
    {
      "adapter": "trtools2_bars",
      "applicable_target_types": [],
      "config": {
        "count": 60,
        "stream": "trtools2:bars:1m",
        "symbol": "VIX",
        "timeframe": "1m"
      },
      "name": "bars_1m_vix"
    },
    {
      "adapter": "trtools2_indicators",
      "applicable_target_types": [],
      "config": {
        "count": 30,
        "stream": "trtools2:indicators"
      },
      "name": "indicators_target"
    },
    {
      "adapter": "trtools2_news",
      "applicable_target_types": [],
      "config": {
        "count": 30,
        "stream": "trtools2:news"
      },
      "name": "news_recent"
    },
    {
      "adapter": "trtools2_strategy_events",
      "applicable_target_types": [],
      "config": {
        "count": 20,
        "stream": "trtools2:strategy:events"
      },
      "name": "strategy_events"
    },
    {
      "adapter": "kronos_forecast",
      "applicable_target_types": [],
      "config": {
        "include_forecast": false,
        "timeframe": "1m"
      },
      "name": "kronos_forecast_1m"
    },
    {
      "adapter": "fomo2_request",
      "applicable_target_types": [],
      "config": {
        "count": 30,
        "days_back": 2,
        "request": "fetch_news",
        "wait": true,
        "wait_seconds": 15
      },
      "name": "fomo2_deep_news"
    },
    {
      "adapter": "fomo2_knowledge",
      "applicable_target_types": [],
      "config": {
        "chromadb_path": "./data/chromadb",
        "days_back": 30,
        "max_results": 10
      },
      "name": "fomo2_knowledge"
    },
    {
      "adapter": "fred_api",
      "applicable_target_types": [],
      "config": {
        "api_key": "",
        "query_type": "macro"
      },
      "name": "macro_context"
    },
    {
      "adapter": "fomo2_items",
      "applicable_target_types": [],
      "config": {
        "count": 30
      },
      "name": "enriched_items"
    }
  ],
  "target_key": "ticker",
  "triggers": [
    {
      "action_mode": "semi",
      "cooldown_s": 60,
      "name": "kronos prob_up shift",
      "on_stream": "kronos:forecasts:emitted",
      "target": {
        "ticker": "{payload.symbol}"
      },
      "when": "abs(payload.prob_up_delta) \u003e 0.15 or payload.direction_flipped"
    },
    {
      "action_mode": "semi",
      "cooldown_s": 300,
      "name": "trtools2 strategy fired",
      "on_stream": "trtools2:strategy:events",
      "target": {
        "ticker": "{payload.symbol}"
      },
      "when": "payload.action == \u0027BUY\u0027 or payload.action == \u0027SELL\u0027"
    }
  ]
}

Data sources bound to this arena. Agents access these via ReAct tool calls.

Source Name	Adapter	Module	Parameters	Used By
bars_1m_target	trtools2_bars	trtools2	—	price_analyst
bars_1m_vix	trtools2_bars	trtools2	—	vol_regime_analyst
indicators_target	trtools2_indicators	trtools2	—	price_analyst, vol_regime_analyst
news_recent	trtools2_news	trtools2	—	news_analyst
strategy_events	trtools2_strategy_events	trtools2	—	price_analyst
kronos_forecast_1m	kronos_forecast	kronos	—	kronos_specialist
fomo2_deep_news	fomo2_request	fomo2	—	—
fomo2_knowledge	fomo2_knowledge	fomo2	—	—
macro_context	fred_api	web	—	—
enriched_items	fomo2_items	fomo2	—	—

Decision trail — every arena run is saved for review and auditing.

Loading memory data...

market_pulse

Phase Pipeline

analysis

synthesis

replan_check

emit

Agent Signals

Execution Trace

Source Monitoring

Agent Reports

Debates

Decisions

Target Context

Metadata

Data sources

Agents

Phases

Smart triggers

Performance Metrics

vs Buy & Hold

Equity Curve

Trades

Signal Timeline