Add temporal data streaming to A2A partial_metrics

- Add end_date, fiscal_year, form fields to MetricEntry
- Update emit_metric() to accept temporal parameters
- Extract temporal data from financials MCP response
- Stream fiscal period info (FY 2023, Q3 2024) via A2A

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

app.py

@@ -68,6 +68,10 @@ class MetricEntry(BaseModel):
     metric: str
     value: Any
     timestamp: str
+    # Temporal fields for financial data
+    end_date: Optional[str] = None      # "2023-09-30"
+    fiscal_year: Optional[int] = None   # 2023
+    form: Optional[str] = None          # "10-K" or "10-Q"
 
 
 class Task(BaseModel):
@@ -235,20 +239,25 @@ async def handle_message_send(params: dict, request_id: Any) -> dict:
 
 def create_progress_callback(task_id: str):
     """Create a progress callback that adds partial metrics to the task."""
-    def callback(source: str, metric: str, value: Any):
+    def callback(source: str, metric: str, value: Any,
+                 end_date: str = None, fiscal_year: int = None, form: str = None):
         task = TASK_STORE.get(task_id)
         if task and task.status == TaskStatus.WORKING:
             entry = MetricEntry(
                 source=source,
                 metric=metric,
                 value=value,
-                timestamp=datetime.now().isoformat()
+                timestamp=datetime.now().isoformat(),
+                end_date=end_date,
+                fiscal_year=fiscal_year,
+                form=form
             )
             if task.partial_metrics is None:
                 task.partial_metrics = []
             task.partial_metrics.append(entry)
             task.updated_at = datetime.now().isoformat()
-            logger.info(f"Task {task_id}: [{source}] {metric} = {value}")
+            temporal_info = f" ({form} {fiscal_year})" if fiscal_year else ""
+            logger.info(f"Task {task_id}: [{source}] {metric} = {value}{temporal_info}")
     return callback
 
 

mcp_client.py

@@ -26,11 +26,20 @@ MCP_SERVERS_PATH = Path(__file__).parent / "mcp-servers"
 METRIC_DELAY_MS = int(os.getenv("METRIC_DELAY_MS", "300"))
 
 
-async def emit_metric(progress_callback: Optional[Callable], source: str, metric: str, value: Any):
-    """Emit a metric event with configurable delay."""
+async def emit_metric(
+    progress_callback: Optional[Callable],
+    source: str,
+    metric: str,
+    value: Any,
+    end_date: str = None,
+    fiscal_year: int = None,
+    form: str = None
+):
+    """Emit a metric event with optional temporal data and configurable delay."""
     if progress_callback:
-        logger.debug(f"emit_metric: {source}/{metric}={value}")
-        progress_callback(source, metric, value)
+        temporal_info = f" ({form} {fiscal_year})" if fiscal_year else ""
+        logger.debug(f"emit_metric: {source}/{metric}={value}{temporal_info}")
+        progress_callback(source, metric, value, end_date, fiscal_year, form)
         await asyncio.sleep(METRIC_DELAY_MS / 1000)
 
 
@@ -256,12 +265,25 @@ async def _extract_and_emit_metrics(
     if source == "financials":
         financials = result.get("financials", {})
         debt = result.get("debt", {})
-        if financials.get("revenue", {}).get("value"):
-            await emit_metric(progress_callback, source, "revenue", financials["revenue"]["value"])
+        # Extract temporal data with metrics
+        revenue = financials.get("revenue", {})
+        if revenue.get("value"):
+            await emit_metric(
+                progress_callback, source, "revenue", revenue["value"],
+                end_date=revenue.get("end_date"),
+                fiscal_year=revenue.get("fiscal_year"),
+                form=revenue.get("form")
+            )
         if financials.get("net_margin"):
             await emit_metric(progress_callback, source, "net_margin", financials["net_margin"])
-        if financials.get("eps", {}).get("value"):
-            await emit_metric(progress_callback, source, "EPS", financials["eps"]["value"])
+        eps = financials.get("eps", {})
+        if eps.get("value"):
+            await emit_metric(
+                progress_callback, source, "EPS", eps["value"],
+                end_date=eps.get("end_date"),
+                fiscal_year=eps.get("fiscal_year"),
+                form=eps.get("form")
+            )
         if debt.get("debt_to_equity"):
             await emit_metric(progress_callback, source, "debt_to_equity", debt["debt_to_equity"])