Fix temporal data flow with structured payload pattern

- research_gateway.py: Pass dict payload instead of positional args
- researcher.py: Add backwards-compatible callback supporting both formats

Ensures fiscal_year, end_date, form fields are preserved through the
A2A → progress_callback → add_metric pipeline.

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

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

src/nodes/research_gateway.py

@@ -146,13 +146,18 @@ async def wait_for_completion(
                 value = metric.get("value")
                 if not source or not metric_name:
                     continue
-                # Extract temporal fields
-                end_date = metric.get("end_date")
-                fiscal_year = metric.get("fiscal_year")
-                form = metric.get("form")
                 metric_key = f"{source}:{metric_name}:{value}"
                 if metric_key not in emitted_metrics:
-                    progress_callback(source, metric_name, value, end_date, fiscal_year, form)
+                    # Pass structured payload dict (matches Researcher-Agent emit_metric)
+                    payload = {
+                        "source": source,
+                        "metric": metric_name,
+                        "value": value,
+                        "end_date": metric.get("end_date"),
+                        "fiscal_year": metric.get("fiscal_year"),
+                        "form": metric.get("form"),
+                    }
+                    progress_callback(payload)
                     emitted_metrics.add(metric_key)
 
         if status == "completed":

src/nodes/researcher.py

@@ -76,12 +76,29 @@ def researcher_node(state, workflow_id=None, progress_store=None):
             add_activity_log(workflow_id, step, message)
 
     # Create progress callback for granular metric events
-    def progress_callback(source: str, metric: str, value,
-                          end_date: str = None, fiscal_year: int = None, form: str = None):
-        if workflow_id and progress_store:
-            # Import here to avoid circular imports
+    # Supports both dict payload (new) and positional args (legacy)
+    def progress_callback(*args, **kwargs):
+        if args and isinstance(args[0], dict):
+            # New structured payload format
+            p = args[0]
+            src = p.get("source")
+            metric = p.get("metric")
+            value = p.get("value")
+            end_date = p.get("end_date")
+            fiscal_year = p.get("fiscal_year")
+            form = p.get("form")
+        else:
+            # Legacy positional args format
+            src = args[0] if len(args) > 0 else kwargs.get("source")
+            metric = args[1] if len(args) > 1 else kwargs.get("metric")
+            value = args[2] if len(args) > 2 else kwargs.get("value")
+            end_date = args[3] if len(args) > 3 else kwargs.get("end_date")
+            fiscal_year = args[4] if len(args) > 4 else kwargs.get("fiscal_year")
+            form = args[5] if len(args) > 5 else kwargs.get("form")
+
+        if workflow_id and progress_store and src and metric:
             from src.services.workflow_store import add_metric
-            add_metric(workflow_id, source, metric, value,
+            add_metric(workflow_id, src, metric, value,
                        end_date=end_date, fiscal_year=fiscal_year, form=form)
 
     try: