Adriano/Cerbero-Bite
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(runtime): orchestrator option-chain snapshot multi-asset (ETH+BTC)

Browse Source 
Sostituisce `option_chain_asset: str = "ETH"` con
`option_chain_assets: tuple[str, ...] = ("ETH", "BTC")` e itera nel
job schedulato. Coerente con `market_snapshot_assets` già multi-asset
e con i 64 strikes BTC + 51 strikes ETH già visibili in
option_chain_snapshots.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
root
2026-05-10 09:00:24 +00:00
parent b1836d91c2
commit efa829f7aa
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cerbero_bite/runtime/orchestrator.py
+3 -4
View File
@@ -222,7 +222,7 @@ class Orchestrator:
market_snapshot_cron: str = _CRON_MARKET_SNAPSHOT, market_snapshot_cron: str = _CRON_MARKET_SNAPSHOT,
market_snapshot_assets: tuple[str, ...] = DEFAULT_ASSETS, market_snapshot_assets: tuple[str, ...] = DEFAULT_ASSETS,
option_chain_cron: str = _CRON_OPTION_CHAIN_SNAPSHOT, option_chain_cron: str = _CRON_OPTION_CHAIN_SNAPSHOT,
option_chain_asset: str = "ETH", option_chain_assets: tuple[str, ...] = ("ETH", "BTC"),
backup_dir: Path | None = None, backup_dir: Path | None = None,
backup_retention_days: int = _BACKUP_RETENTION_DAYS, backup_retention_days: int = _BACKUP_RETENTION_DAYS,
) -> AsyncIOScheduler: ) -> AsyncIOScheduler:
@@ -290,9 +290,8 @@ class Orchestrator:
async def _option_chain_snapshot() -> None: async def _option_chain_snapshot() -> None:
async def _do() -> None: async def _do() -> None:
await collect_option_chain_snapshot( for asset in option_chain_assets:
self._ctx, asset=option_chain_asset await collect_option_chain_snapshot(self._ctx, asset=asset)
)
await _safe("option_chain_snapshot", _do) await _safe("option_chain_snapshot", _do)