ReMe/cookbook/auto-fin
jinliyl 1687179f84
Some checks are pending
Pre-commit / run (ubuntu-latest) (push) Waiting to run
Tests ReMe / Unit Tests - py3.13 (push) Waiting to run
Tests ReMe / Unit Tests - py3.11 (push) Waiting to run
Tests ReMe / Unit Tests - py3.12 (push) Waiting to run
Windows Smoke / CLI smoke - py3.11 (push) Waiting to run
feat: add Auto Fin cookbook and managed outbound proxy support (#392)
* feat: add ssh proxy

* feat: add ssh proxy

* feat: add ssh proxy

* feat: add ssh proxy

* feat: add prompt

* feat: add agent wrapper

* feat: add agent wrapper

* feat: add agent wrapper

* feat: add tushare skill

* feat: add tushare skill

* feat: add tushare skill

* feat: add none stream

* chore(deps): update dependency versions in pyproject.toml

- Bump claude-agent-sdk from 0.2.123 to 0.2.126
- Upgrade pre-commit to version 4.6.1 or higher
- Upgrade pytest to version 9.1.1 or higher

* feat(agent_wrapper): add session compaction support and unify session commands

- Introduce compact_session method to BaseAgentWrapper and implement it in AsAgentWrapper, CcAgentWrapper, and CodexAgentWrapper
- Add session_command module with SessionCommandResult dataclass and handle_session_command function for /clear and /compact commands
- Update __init__.py exports to include session_command handlers
- Modify DingTalkWaitStep to handle session commands via handle_session_command function
- Remove streaming mode from DingTalkWaitStep and simplify reply handling to final Markdown replies only
- Add unit tests for session compaction methods and session command handling across wrappers and DingTalk integration
- Clean up and remove obsolete streaming and card rendering code from DingTalk wait step
- Adjust daily_cookbook.yaml to remove stream and card_update_interval config entries for DingTalk wait step

* feat(auto_fin): add Auto Fin simulated portfolio cookbook workflow

- Add comprehensive Auto Fin schema exports for multiple models and enums
- Implement base class and helpers for Auto Fin analysis steps
- Create file, state, and formatting utilities for Auto Fin with atomic file writes and locking
- Define Auto Fin pipeline with four analysis agents: backtest, event, portfolio, and US correlation
- Register Auto Fin package in cookbook workflows and schema initialization
- Add detailed documentation in markdown describing the system design, workflow, and data contracts

* feat(outbound_proxy): add application-scoped outbound HTTP proxy components

- Introduce BaseOutboundProxy and OutboundProxyEndpoint as core contracts
- Implement FixedHttpOutboundProxy for external HTTP proxy integration
- Add SshHttpOutboundProxy providing SSH-backed local HTTP proxy tunnels
- Register outbound proxy components in component registry and enumeration
- Update components package to include outbound_proxy module
- Add dependency on pproxy for SSH HTTP proxy bridging
- Include comprehensive unit tests covering proxy lifecycle, validation,
  environment merging, error handling, readiness, and monitoring mechanisms

* refactor(network): replace SSH proxy with explicit HTTP outbound proxy

- Remove SSH proxy helper implementation and references in codebase
- Add support for explicit HTTP proxy URL in arXiv and HuggingFace clients
- Modify clients to use async context manager for consistent resource handling
- Update daily paper steps to forward outbound proxy configuration explicitly
- Change tests to cover new proxy usage model and remove SSH proxy mocks
- Add outbound proxy component configuration in daily_cookbook.yaml
- Ensure proxy URL usage disables environment trust in HTTP clients
- Fix app context component enum access to be defensive against missing keys

* feat(agent_wrapper): add managed proxy support for command environments

- Introduce BaseOutboundProxy binding in BaseAgentWrapper for outbound proxy management
- Add bash_environment and command_proxy_environment properties to apply proxy settings
- Update WorkspaceBackend instantiation in AsAgentWrapper to use bash_environment
- Inject managed proxy export commands into Claude Code Bash commands via hooks
- Enhance CodexAgentWrapper to include managed proxy in shell environment policy
- Modify daily_cookbook.yaml steps to specify outbound_proxy as default where needed
- Add comprehensive unit tests verifying managed proxy injection and environment isolation
- Ensure subprocess_environment remains unchanged while proxy is applied selectively to commands

* refactor(memory): replace search job_tools with memory in daily cookbook config

- Change workspace_dir default from .reme to reme_workspace
- Replace search job_tools with memory across multiple components and jobs
- Update descriptions to reflect long-term memory retrieval instead of search
- Modify system prompts to instruct using memory for retrieving notes
- Adjust unit tests to verify memory job_tools and job presence instead of search
- Ensure consistency in configuration and tests for memory backend usage

* refactor(config): rename memory to memory_search in daily cookbook config

- Change all occurrences of "memory" to "memory_search" in job_tools and job definitions
- Update related system prompts to reflect the new memory_search terminology
- Modify unit tests to assert the presence of memory_search instead of memory
- Ensure consistency across skills, job tools, and backend configurations in multiple components

* feat(auto_fin): add deterministic quantitative research and ranking fusion

- Introduce new schema models: EtfScore, RankingMetrics, ExtremeAnalysis,
  DimensionRanking, and FusionRanking to represent deterministic research outputs
- Add ranking data to event, backtest, us_correlation, and portfolio analysis outputs
- Implement ranking_section renderer to format Top20 scores and diagnostics in Markdown
- Develop AutoFinQuantStep for deterministic ETF ranking using TuShare data, Polars,
  and a custom extremely randomized tree ensemble
- Integrate quantitative rankings into backtest and portfolio analysis steps and reports
- Extend auto_fin pipeline with new quant_enabled and quant_required config options
- Enforce ranking constraints like unique codes, contiguous ranks, and normalized fusion weights
- Update analysis YAMLs with rules limiting data freshness, universe, and ranking usage
- Incorporate ranking outputs into all major markdown report bodies in Auto Fin pipeline
- Add concurrency-limited asynchronous TuShare client to fetch required market data
- Introduce cross-sectional rank correlation and NDCG metrics for ranking quality evaluation

* feat(auto_fin): implement stage-wise notification and reporting for analysis pipeline

- Refactor notification config in daily_cookbook.yaml to support dispatch steps
- Update AutoFinNotificationStep to deduplicate notifications per run stage
- Add _notify_stage method in pipeline to send notifications for each analysis stage
- Implement persistence and notification for event, backtest, US correlation, and portfolio stages
- Modify pipeline flow to persist reports and notify after each stage completion
- Adjust metadata to track notifications and errors per stage
- Update tests to verify stage-wise notification sending and deduplication
- Remove older combined report persistence in favor of modular stage handling

* feat(auto_fin): add outbound proxy support for Tushare API usage

- Introduce BaseOutboundProxy reference in AutoFinPipelineStep and AutoFinQuantStep
- Update TushareResearchClient and trade calendar fetch to accept and use proxy URL
- Create _ProxiedTushareApi adapter to route Tushare requests via explicit HTTP proxy
- Modify create_tushare_api utility to optionally return proxied API client
- Add unit tests covering proxy forwarding and client behavior with managed proxies
- Ensure proxy usage respects explicit proxy URL over environment fallback
- Integrate outbound proxy into data fetching and quantitative research steps

* feat(auto_fin): enforce checkpoint time validation and add state models

- Introduce AnalysisState base class and specific states for event, backtest, and US correlation analyses
- Replace analysis output types with corresponding state classes in run schemas
- Add require_checkpoint_reached method to validate decision_at/data_cutoff against current time
- Enforce checkpoint time checks before analysis steps in event, backtest, portfolio, and quant analyses
- Refactor quant data loading to include adjustment factors and apply price adjustments without fallback
- Update analysis YAML docs to require real-time checkpoint validation and forbid using future data
- Improve portfolio run serialization by excluding redundant legacy fields and nested proposed actions
- Add helper to extract readable sections from persisted checkpoint documents
- Fix event analysis output validation to reject events and sources with future timestamps

* feat(auto_fin): auto-select latest reached checkpoint if none specified

- Extend checkpoint config to accept empty string for auto selection
- Add static method to compute latest checkpoint reached by current time
- Modify pipeline step to auto-select checkpoint based on trade calendar and time
- Adjust force flag default depending on whether checkpoint is explicit or auto
- Log details when checkpoint is auto-selected to improve observability
- Add comprehensive tests for auto checkpoint selection logic and edge cases
- Remove deprecated default and required constraints from force parameter in config

* refactor(auto_fin): unify datetime comparison with compare_datetimes utility

- Replace direct datetime comparisons with compare_datetimes function calls
- Use cmp_to_key with compare_datetimes for sorting datetime tuples and lists
- Update validation logic in backtest, event, analysis, and ledger modules for consistent datetime handling
- Add unit tests to verify handling of naive and aware datetime comparisons in event and backtest validations
- Ensure marked_at and interval_end timestamps are set and compared consistently using compare_datetimes
- Improve correctness of ordering and conditional checks related to timestamps throughout auto_fin steps and ledger code

* feat(auto_fin): add datetime comparison helper for mixed timezone data

- Implement compare_datetimes function to handle naive and aware datetimes
- Ensure naive datetime is interpreted in the known timezone of the counterpart
- Facilitate comparisons between legacy and timezone-aware Auto Fin data
- Add module docstring explaining purpose of the helpers

* docs(auto_fin): enforce unique ETF representative per sub-theme in analysis rules

- Update backtest.yaml to recommend or highlight only one ETF per sub-theme for ETF analyses
- Modify event.yaml to map only one representative ETF per sub-theme, avoiding duplicate recommendations
- Revise portfolio.yaml to restrict holdings/buys to a single ETF per sub-theme, preventing repeated buys of highly overlapping ETFs
- Adjust us_correlation.yaml to retain only one representative A-share ETF per sub-theme for mapping or recommendation
- Add test to verify presence of new sub-theme uniqueness guidance in step prompts

* feat(auto_fin): separate draft model and include deterministic fusion ranking

- Introduce _PortfolioProposalDraft pydantic model for agent-authored fields before ranking
- Discard any "fusion_ranking" data from draft to prevent conflicts with canonical ranking
- Modify AutoFinPortfolioStep to receive draft, enrich with fusion_ranking, and produce final output
- Update tests to use _PortfolioProposalDraft and validate deterministic fusion ranking propagation
- Add async test verifying fusion ranking is correctly set in portfolio output with no errors

* refactor(auto_fin): rewrite and simplify Auto Fin schema and steps

- Remove legacy Auto Fin analysis step modules and helpers
- Replace complex ranking and portfolio models with simplified current-news models
- Update schema to focus on news-case workflow with new domain models
- Remove A-share decision checkpoints and backtest details from schema
- Simplify recommendation and decision output structures
- Clean up deprecated state and utility functions
- Update Auto Fin steps initialization to new pipeline steps only
- Improve uniqueness validation for themes and ETFs in research plan

* feat(auto_fin): implement full local cache and analysis workflow for Auto Fin

- Add AutoFinDataStep to prepare and cache daily TuShare data with lookback
- Add AutoFinAnalysisStep to analyze cached data and generate Markdown report
- Implement detailed time window, ETF filtering, and historical case validation
- Introduce YAML prompts for planning and decision-making steps
- Update .gitignore to include reme_workspace/
- Clean up config and import structure for auto_fin steps
- Remove old pipeline.py and consolidate functionality into new modules
- Use polars for efficient CSV reading and data processing
- Ensure atomic writes and strict JSON serialization for cache files
- Enforce rules on news timing, ETF universe, and historical case usage

* fix(auto_fin): restrict news data source to '财联社' in analysis and cache

- Update analysis templates to specify current news as from '财联社' only
- Modify news fetching functions to filter by source '财联社'
- Add validation method to check cached news source correctness
- Update news caching logic to exclude non-'财联社' news
- Enhance unit tests with multiple sources to ensure filtering works
- Confirm news API calls include source filter parameter as '财联社'

* refactor(auto_fin): convert I/O methods to asynchronous implementations

- Change _news, _dataset, and _theme_data methods to async for improved concurrency
- Move JSONL and CSV reading operations to asynchronous wrappers using asyncio.to_thread
- Remove synchronous _read_jsonl and _read_csv functions, integrate them as static async class methods
- Update cache validation methods to async, awaiting I/O operations accordingly
- Adjust usage of dataset and news retrieval in analysis step to await asynchronous methods
- Add async unit test to validate JSONL reading with unicode line separators
- Preserve existing functionality while enabling non-blocking file and data access

* fix(nx_file_graph): defer networkx import and improve dependency handling

- Move networkx import inside NxFileGraph constructor for lazy loading
- Raise ImportError with original exception context if networkx is missing
- Remove module-level fallback assignment of nx to None
- Expand test to block loading of multiple optional core dependencies eagerly
- Change exception type in test from ModuleNotFoundError to AssertionError
- Update test comments to reflect broader optional dependency checks

* feat(embedding_store): add quota retry delay mechanism for embedding requests

- Introduce quota_retry_delay parameter to configure wait time before retry on quota exhaustion
- Implement detection of insufficient quota errors in LocalEmbeddingStore without external SDK
- Add retry logic with custom delay when quota is insufficient during embedding requests
- Update configuration to set max_retries and quota_retry_delay defaults for embedding store
- Add unit tests covering quota exhaustion retry behavior with delay and opt-in control
- Ensure existing retry behavior remains unchanged if quota_retry_delay is not set

* feat(auto_fin): add detailed logging to analysis and data fetching steps

- Add _preview static method for bounded diagnostic output in analysis.py
- Log prompt start, completion, errors, and validation details in _reply method
- Add info logs for major processing steps in execute method of analysis.py
- Add debug and info logs for cache validation, data fetching, and pagination in data.py
- Log conditions for skipping reports and cache plans in data.py execute method
- Log download summaries and cache writes for news and ETF data
- Improve error logging with exception details in cache validation functions
- Ensure all logs include context such as record counts, paths, and parameters

* refactor(auto_fin): overhaul Auto Fin workflow and schema contracts

- Replace old Auto Fin schema models with comprehensive new data classes
- Remove legacy Auto Fin analysis step in favor of modular agent-based steps
- Introduce AutoFinAgentStep for validating structured agent replies
- Simplify data cleaning and JSONL writing utilities for news cache
- Remove synchronous and asynchronous dataset methods from analysis step
- Redefine Auto Fin analysis configuration for 360-day news retention and multi-step pipeline
- Remove embedded analysis prompt templates and replace with agent-driven logic
- Update __init__.py exports to match new step implementations and remove deprecated classes
- Improve error handling and validation in agent step reply processing
- Clean up redundant imports and unused code in analysis and data preparation modules

* feat(auto_fin): add detailed logging for analysis and data processing steps

- Add timing logs to measure agent prompt processing duration in analysis.py
- Log news cache hits and news write paths with record counts in data.py
- Include detailed info logs for news download start and completion in data.py
- Add start, progress, and completion logs with topic and event counts in history.py
- Log start and completion of merge step including path and ETF count in merge.py
- Add start and done logs with window and news counts in topic.py

* feat(auto_fin): enhance schema and steps with detailed ETF and event modeling

- Replace and add multiple AutoFin schema classes to support detailed ETF selection,
  historical research, market analysis, forecast models, and report output with validation
- Implement Shanghai timezone normalization and strict validation in schema models
- Remove deprecated AutoFin analysis agent step and consolidate reply handling in base step
- Introduce AutoFinStep base class with shared helpers for prompt handling, data fetching,
  logging, and JSONL file operations
- Add AutoFinDataStep to manage daily news data complete with schedule validation, caching,
  and source validation logic
- Update cookbook configuration to customize auto_fin step parameters and simplify
  outbound proxy settings
- Refactor imports and clean unused code for better maintainability

* feat(auto_fin): introduce detailed historical event resolution and market similarity analysis

- Add AutoFinHistoricalEventReference and AutoFinHistoricalSimilarity models for refined event referencing and similarity judgment
- Implement validation to ensure non-empty critical fields and uniqueness of historical news IDs
- Develop method to resolve Agent-selected historical event references from workspace files with strict path and existence checks
- Enrich historical events with market entry and future returns data after resolution
- Redesign market step to calculate similarity-weighted ETF forecasts based on matched historical event similarities
- Enforce validation on matched historical events for uniqueness and proper weight summation
- Simplify merge step output to final Markdown report without YAML frontmatter and redundant fields
- Update user instructions for history search, market, and merge steps to reflect new data structures and responsibilities
- Adjust test suite to cover new schema and step behavior changes, including enhanced validation and JSON output formats

* feat(auto_fin): add new cron jobs and output analysis jsonl

- Add new cron jobs auto_fin_1145_cron and auto_fin_1800_cron with auto_fin_steps
- Change auto_fin_0930_cron schedule to run Monday to Sunday
- Extend merge step to write analysis data to auto_fin_analysis.jsonl
- Update unit tests to verify new cron jobs and their steps configuration

* fix(auto_fin): improve atomic file write and refresh daily index

- Change temporary file naming to include UUID for uniqueness and hidden prefix
- Replace atomic write method from using Path.replace to os.replace with safe unlink
- Add import and use os.replace for safer file replace operation
- Refresh daily index after writing auto finance markdown and JSONL files
- Import and call refresh_day_index in merge step to update file index asynchronously

* docs(cookbook): add optional SSH proxy configuration in README files

- Introduce optional SSH proxy setup in auto-fin and daily_paper cookbooks
- Provide instructions to enable outbound proxy via `daily_cookbook.yaml` and environment variables
- Add `REME_PROXY_IP` and `REME_PROXY_ACCOUNT` environment variables descriptions in multiple README files
- Update English and Chinese README and README_ZH documents with proxy details
- Maintain consistent formatting of environment variable tables across documents

* fix(file_io): include schema_version in hidden metadata keys

- Added "schema_version" to _INDEX_HIDDEN_METADATA_KEYS in _daily_index.py
- Updated _render_notes_block to always include additional keys regardless of schema_version

fix(deps): move pproxy dependency to later in pyproject.toml

- Removed pproxy from early dependencies list
- Added pproxy back near the end of dependency list for better ordering

fix(outbound_proxy): require pproxy package for ssh_http proxy

- Added importlib.util check for pproxy package presence
- Raise RuntimeError if pproxy is not installed when using SSH HTTP outbound proxy
- Improved error message suggests installing reme-ai with 'core' extra

* docs(readme): update News section with new Cookbook workflows

- Clarify introduction of optional Cookbooks with Daily Paper and Auto Fin workflows
- Update English README to reflect both paper discovery and file-native ETF event research
- Revise Chinese README to include financial news and historical market data research capability
- Maintain announcement of paper acceptance at Findings of ACL 2026

* feat(auto_fin): add calculation results to final Markdown output

- Implement _calculation_results to summarize forecast for each ETF analyzed
- Include program-calculated results in the JSON input for the Markdown report
- Update YAML template to incorporate calculation results and adjust recommendation rules
- Refine recommendation logic to rely on event impact judgments combined with calculation outputs
- Modify tests to verify presence of calculation results and updated report content and format

* up prompt

* fix(keyword_index): ignore non-indexable chunks during keyword sync

- Add is_indexable method to base and BM25 keyword index classes to check text tokenizability
- Update local file store to exclude non-indexable chunks from expected document IDs to prevent rebuild
- Fix JSONL chunker to correctly handle Unicode line separator U+2028 inside JSON strings without splitting
- Add test to ensure non-empty but non-indexable chunk does not trigger keyword index rebuild
- Add test to verify U+2028 character does not cause incorrect JSONL record splitting
2026-07-25 18:09:39 +08:00
..
README.md feat: add Auto Fin cookbook and managed outbound proxy support (#392) 2026-07-25 18:09:39 +08:00
README_ZH.md feat: add Auto Fin cookbook and managed outbound proxy support (#392) 2026-07-25 18:09:39 +08:00

Auto Fin Cookbook

中文

Auto Fin is a local-first, file-native ETF event-research workflow. It identifies market events in CLS news, selects related liquid ETFs, studies similar historical events and subsequent returns, and produces a Chinese research report.

Auto Fin provides event research and holding-period references only. It is not investment advice, does not connect to a broker, and does not place or simulate trades.

Capabilities

  • Download CLS news through Tushare and maintain up to 360 days of traceable local news records.
  • Rank ETF candidates by previous-trading-day turnover, then select representative ETFs related to current events.
  • Search ReMe memory and local news files for similar historical events, with strict source-path and news-ID checks.
  • Calculate adjusted D1–D10 historical returns in deterministic code instead of asking an Agent to invent numbers.
  • Let an Agent judge event similarity, then calculate weights, expected returns, and a reference holding period in code.
  • Save readable Markdown and structured JSON/JSONL artifacts, refresh the daily index, and optionally deliver the report to DingTalk.

The workflow is assembled by daily_cookbook.yaml. Its public schemas are in reme/schema/auto_fin.py, and its steps are in reme/steps/cookbook/auto_fin/.

Quick start

Auto Fin requires Python 3.11 or newer, the core dependencies, a Tushare token, and credentials for the configured Claude Code-compatible endpoint.

From the repository root:

python -m pip install -e ".[core]"
export TUSHARE_TOKEN="your-tushare-token"
export CLAUDE_CODE_API_KEY="your-api-key"
reme start config=daily_cookbook job=auto_fin

The built-in configuration uses qwen3.7-max through DashScope's Anthropic-compatible endpoint. Override these variables to use another compatible model or provider:

export CLAUDE_CODE_MODEL_NAME="your-model"
export CLAUDE_CODE_BASE_URL="https://your-anthropic-compatible-endpoint"

The default workspace is reme_workspace/. This standalone cookbook shares its workspace setting with the daily-paper workflow:

export DAILY_PAPER_WORKSPACE_DIR="/absolute/path/to/reme-workspace"

To deliver the final Markdown report to DingTalk, set:

export DINGTALK_APP_KEY="your-app-key"
export DINGTALK_APP_SECRET="your-app-secret"
export DINGTALK_ROBOT_CODE="your-robot-code"
export DINGTALK_CONVERSATION_IDS="conversation-id-1,conversation-id-2"

DingTalk delivery is skipped when the required values are empty.

Dates and times use Asia/Shanghai. The optional date must be the current date:

reme start config=daily_cookbook job=auto_fin date=2026-07-25

To refresh every configured news day instead of reusing valid historical files:

reme start config=daily_cookbook job=auto_fin force=true

This may issue many Tushare requests. A normal run reuses valid historical news files and always refreshes today's file.

Optional SSH proxy

The outbound proxy is disabled by default. To enable it, uncomment components.outbound_proxy.default in daily_cookbook.yaml, configure non-interactive SSH authentication, and set:

export REME_PROXY_IP="your-ssh-proxy-host"
export REME_PROXY_ACCOUNT="your-ssh-account"

How it works

flowchart LR
    A[Resolve run date and cutoff] --> B[Maintain CLS news files]
    B --> C[Resolve previous A-share trading day]
    C --> D[Build current event window]
    D --> E[Filter liquid ETF candidates]
    E --> F[Agent selects related ETFs]
    F --> G{For each ETF}
    G --> H[Agent searches historical events]
    H --> I[Code resolves original news]
    I --> J[Code calculates adjusted D1-D10 returns]
    J --> K[Agent judges similarity]
    K --> L[Code calculates weighted forecast]
    L --> G
    G --> M[Agent writes the combined report]
    M --> N[Write artifacts and refresh daily index]
    N --> O[Optional DingTalk delivery]

The top-level job contains four Auto Fin steps:

Step Responsibility Agent
auto_fin_data_step Maintain news files and resolve the previous trading day No
auto_fin_topic_step Build inputs and select related ETFs and current events Yes
auto_fin_history_step Orchestrate historical research and market analysis per ETF Yes
auto_fin_merge_step Validate results and produce the final Markdown report Yes

For each selected ETF, auto_fin_history_step dispatches:

  • auto_fin_history_search_step, which asks the Agent for historical news references and then resolves the original records and calculates their returns in code.
  • auto_fin_market_step, which asks the Agent only for similarity judgments and then calculates weights and forecasts in code.

Agents handle semantic judgments; deterministic code handles source validation and financial calculations.

Data and time boundaries

News history

auto_fin_data_step reads CLS news from Tushare's major_news endpoint:

  • The default lookback is 360 calendar days, including the run date.
  • A valid historical file is reused unless force=true.
  • Today's file is refreshed through the current decision_at on every run.
  • Large responses are fetched through recursively split time windows.
  • Records are ordered and deduplicated before being written with a stable news_id.

The current event window is:

(previous A-share trading day at 15:00, decision_at]

Each run rebuilds this complete window; midday and evening runs do not use only the increment since the previous run.

ETF candidates

The candidate universe combines:

  • etf_basic for currently listed ETFs and their tracked indexes.
  • fund_daily for turnover on the previous A-share trading day.

Code sorts candidates by turnover, removes duplicates by ETF name and index identity, and provides at most 150 candidates to the Topic Agent. The Agent may return at most 20 ETFs and must copy every ETF code, name, and news ID from the generated candidate files.

Turnover is used only to narrow the research universe; it is not a trading signal.

Historical research and forecasting

Source resolution

The History Agent searches by event type, entities, transmission mechanism, and expected direction. It first uses memory_search and may then scan:

daily/YYYY-MM-DD/auto_fin_news_data.jsonl

Its output contains only a reason, news_id, and workspace-relative source_path. Code rejects:

  • Current-window news presented as historical evidence.
  • Absolute paths, .. traversal, or paths outside the workspace.
  • Sources not named auto_fin_news_data.jsonl.
  • Missing files or IDs that do not resolve exactly once.
  • Records without a usable publication time, title, or body.

Historical Markdown may guide retrieval, but the original news JSONL is the source of truth.

Adjusted returns

For every resolved historical event, code reads fund_daily and fund_adj and calculates up to ten future closes:

  • Before 09:30 on a trading day: enter at that day's open.
  • From 09:30 until before 15:00: enter at that day's close.
  • At or after 15:00, or on a non-trading day: enter at the next trading day's open.
  • A daily close later than the current decision_at is excluded.
adjusted_entry = raw_entry × entry_adjustment_factor
adjusted_close = raw_close × close_adjustment_factor
cumulative_return = adjusted_close / adjusted_entry - 1

Missing prices, factors, trading days, or horizons become explicit limitations. They are never filled with Agent-made values.

Similarity and forecast

The Market Agent returns semantic similarity in [-1, 1]:

  • Positive values mean a similar mechanism and direction.
  • Negative values mean a comparable mechanism but opposite direction.
  • Zero means no useful relationship.

Code clamps out-of-range values, ignores zero-similarity events, normalizes weights from absolute similarity, and reverses the historical return direction for negative matches. Each D1–D10 horizon is calculated from the samples available at that horizon. The suggested holding period is the positive-return horizon with the highest expected return, or empty when none is positive.

The result also records limited samples, missing horizons, conflicting return directions, and other data limitations. It is a comparison with a small historical sample, not evidence of statistical significance.

Output layout

reme_workspace/
├── daily/
│   ├── YYYY-MM-DD.md
│   └── YYYY-MM-DD/
│       ├── auto_fin_news_data.jsonl
│       ├── auto_fin_analysis.jsonl
│       └── auto_fin.md
└── resource/
    └── YYYY-MM-DD/
        ├── filtered_news.jsonl
        ├── filtered_etf.jsonl
        ├── auto_fin_topic_output.jsonl
        ├── auto_fin_history_<index>_<ETF-code>_output.json
        ├── auto_fin_market_<index>_<ETF-code>_output.json
        ├── auto_fin_history_output.jsonl
        └── auto_fin_merge_output.json

Important artifacts:

  • auto_fin_news_data.jsonl is the user-owned source used to resolve historical news.
  • filtered_news.jsonl and filtered_etf.jsonl are bounded inputs for the Topic Agent.
  • Per-ETF history files contain resolved source news and code-calculated return paths.
  • Per-ETF market files contain code-calculated matches, weights, and D1–D10 forecasts.
  • auto_fin_analysis.jsonl contains the final structured analysis for every selected ETF.
  • auto_fin.md is the readable report and DingTalk payload.
  • daily/YYYY-MM-DD.md is refreshed after report generation so the report is discoverable from the daily index.

News and reports remain ordinary user-owned files. Resource artifacts and search indexes can be rebuilt.

Configuration

Job parameters

Parameter Default Meaning
date Current date Strict YYYY-MM-DD; only the current date is supported
force false Refresh all configured news days

Environment variables

Variable Required Meaning
TUSHARE_TOKEN Yes News, calendar, ETF daily data, and adjustment factors
CLAUDE_CODE_API_KEY Yes Auto Fin Agent credentials
CLAUDE_CODE_MODEL_NAME No Defaults to qwen3.7-max
CLAUDE_CODE_BASE_URL No Anthropic-compatible endpoint
AUTO_FIN_AGENT_BACKEND No Defaults to claude_code
AUTO_FIN_PROJECT_PATH No Agent project path; defaults to ..
REME_PROXY_IP No SSH proxy host; used only when ssh_http is enabled
REME_PROXY_ACCOUNT No SSH proxy account; used only when ssh_http is enabled
DAILY_PAPER_WORKSPACE_DIR No Standalone cookbook workspace
DINGTALK_* No DingTalk application, robot, and conversation settings

Unit tests can inject tushare_provider through the runtime context and do not require real credentials.

Scheduled jobs

daily_cookbook.yaml defines:

Job Cron Asia/Shanghai
auto_fin_0930_cron 30 9 * * * Daily at 09:30
auto_fin_1145_cron 45 11 * * * Daily at 11:45
auto_fin_1800_cron 0 18 * * * Daily at 18:00

These cron expressions do not exclude weekends or market holidays. The workflow resolves the previous A-share trading day but does not currently skip a run merely because the run date is not a trading day.

Agent and security boundaries

The Auto Fin wrapper loads the tushare-data skill, exposes the memory_search job tool, and defaults to bypassPermissions. Prompts constrain each Agent's role, while code revalidates schemas, ETF identities, source paths, news references, and calculated values.

The standalone cookbook does not configure an embedding store by default, so memory_search normally uses BM25 recall. Vector and BM25 fusion becomes available only when an embedding store is configured.

bypassPermissions is not an operating-system sandbox. Review the configured project path, workspace, credentials, and network boundary before deployment.

Reruns and limitations

  • Valid historical news files are reused; today's news is always refreshed.
  • Outputs use stable per-day paths, so a later same-day run replaces the previous report and resource outputs.
  • Auto Fin intentionally has no “report exists, skip” shortcut because its scheduled runs analyze updated news.
  • Every successful run attempts DingTalk delivery when configured; notification deduplication is not implemented.
  • Missing historical market horizons degrade one sample and are recorded as limitations.
  • Invalid dates, missing required services, invalid Agent schemas, unknown ETFs or news IDs, unsafe paths, and inconsistent cross-step ETF identities fail the job.

The current implementation does not include stocks, US-market correlation, portfolio accounting, BUY/SELL/HOLD actions, T+1 execution rules, fees, slippage, broker integration, or real/simulated order execution.

Development

Install development dependencies and run the focused suite:

python -m pip install -e ".[dev,core]"
PYTHONPATH=. pytest tests/unit/test_auto_fin.py -v

The unit suite mocks model and market-data boundaries. Tests requiring real Tushare, model, or DingTalk credentials should be run separately and only with explicit authorization.