Celes Renata
bc077bfcc8
ci/woodpecker/push/test Pipeline was successful
ci/woodpecker/push/build-2 Pipeline was successful
ci/woodpecker/push/build-3 Pipeline was successful
ci/woodpecker/push/build-1 Pipeline was successful
ci/woodpecker/push/finalize Pipeline was successful
Build and Push / lint-and-test (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.adapters.broker_adapter name:broker-adapter]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.aggregation.worker name:aggregation]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.extractor.worker name:extractor]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.ingestion.worker name:ingestion]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.lake_publisher.worker name:lake-publisher]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.parser.worker name:parser]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.recommendation.worker name:recommendation]) (push) Has been cancelled
Build and Push / build-services (map[cmd:python -m services.scheduler.app name:scheduler]) (push) Has been cancelled
Build and Push / build-services (map[cmd:uvicorn services.api.app:app --host 0.0.0.0 --port 8000 name:query-api]) (push) Has been cancelled
Build and Push / build-services (map[cmd:uvicorn services.risk.app:app --host 0.0.0.0 --port 8000 name:risk]) (push) Has been cancelled
Build and Push / build-services (map[cmd:uvicorn services.symbol_registry.app:app --host 0.0.0.0 --port 8000 name:symbol-registry]) (push) Has been cancelled
Build and Push / build-services (map[cmd:uvicorn services.trading.app:app --host 0.0.0.0 --port 8000 name:trading-engine]) (push) Has been cancelled
Build and Push / build-dashboard (push) Has been cancelled
Build and Push / build-superset (push) Has been cancelled
Build and Push / integration-test (push) Has been cancelled
Build and Push / beta-gate (push) Has been cancelled
- Migration 038: trading_reports table + report-summarizer agent seed
- 6 reporting modules: models, collector, sections, validator, summarizer, generator
- API endpoints: GET /api/reports (paginated, filterable), GET /api/reports/{id}
- Frontend hooks: useReports, useReport with TanStack Query
- Scheduler: daily (after 16:30 ET) and weekly (Saturday) report triggers
- Redis queue consumer for async report generation with retry/dedup
- 5 property-based tests (chunking, serialization, validation, accuracy, deltas)
- 109 unit/integration tests across all modules
- 6 frontend hook tests with MSW mocks
105 lines
2.5 KiB
Python
105 lines
2.5 KiB
Python
from __future__ import annotations
|
|
|
|
from datetime import date, datetime
|
|
from enum import Enum
|
|
|
|
from pydantic import BaseModel, Field
|
|
|
|
|
|
class ReportType(str, Enum):
|
|
DAILY = "daily"
|
|
WEEKLY = "weekly"
|
|
|
|
|
|
class ValidationStatus(str, Enum):
|
|
PASSED = "passed"
|
|
WARNINGS = "warnings"
|
|
|
|
|
|
class ValidationWarning(BaseModel):
|
|
field_name: str
|
|
computed_value: float
|
|
snapshot_value: float
|
|
pct_difference: float
|
|
|
|
|
|
class PLSection(BaseModel):
|
|
realized_pnl: float
|
|
unrealized_pnl: float
|
|
daily_return: float
|
|
cumulative_return: float
|
|
win_count: int
|
|
loss_count: int
|
|
win_rate: float
|
|
profit_factor: float
|
|
sharpe_ratio: float
|
|
summary: str = ""
|
|
validation_warnings: list[ValidationWarning] = Field(default_factory=list)
|
|
|
|
|
|
class RecommendationAccuracySection(BaseModel):
|
|
total_evaluated: int
|
|
act_count: int
|
|
skip_count: int
|
|
acted_win_rate: float
|
|
avg_confidence_acted: float
|
|
avg_confidence_skipped: float
|
|
summary: str = ""
|
|
validation_warnings: list[ValidationWarning] = Field(default_factory=list)
|
|
|
|
|
|
class PositionDetail(BaseModel):
|
|
ticker: str
|
|
entry_price: float
|
|
current_or_exit_price: float
|
|
pnl: float
|
|
pnl_pct: float
|
|
hold_duration_hours: float
|
|
status: str # "open" or "closed"
|
|
|
|
|
|
class PositionPerformanceSection(BaseModel):
|
|
positions: list[PositionDetail] = Field(default_factory=list)
|
|
summary: str = ""
|
|
|
|
|
|
class RiskMetricsSection(BaseModel):
|
|
current_risk_tier: str
|
|
portfolio_heat: float
|
|
max_drawdown: float
|
|
current_drawdown_pct: float
|
|
reserve_pool_balance: float
|
|
circuit_breaker_event_count: int
|
|
summary: str = ""
|
|
|
|
|
|
class ModelQualityWindow(BaseModel):
|
|
lookback: str
|
|
win_rate: float | None
|
|
directional_accuracy: float | None
|
|
information_coefficient: float | None
|
|
calibration_error: float | None
|
|
brier_score: float | None
|
|
|
|
|
|
class ModelQualitySection(BaseModel):
|
|
windows: list[ModelQualityWindow] = Field(default_factory=list)
|
|
summary: str = ""
|
|
validation_warnings: list[ValidationWarning] = Field(default_factory=list)
|
|
|
|
|
|
class ReportData(BaseModel):
|
|
"""Top-level report structure stored as JSONB."""
|
|
|
|
pnl: PLSection
|
|
recommendation_accuracy: RecommendationAccuracySection
|
|
position_performance: PositionPerformanceSection
|
|
risk_metrics: RiskMetricsSection
|
|
model_quality: ModelQualitySection
|
|
executive_summary: str = ""
|
|
validation_status: ValidationStatus = ValidationStatus.PASSED
|
|
generated_at: datetime
|
|
period_start: date
|
|
period_end: date
|
|
report_type: ReportType
|