fix(intake): accept ATIF observation on all step types

docs/cli/reference.mdx

@@ -4047,6 +4047,11 @@ Filter jobs by workspace, project, name, status, source, created_at, and updated
 
 Get all currently configured execution profiles.
 
+Returns the capability-filtered merge from jobs config. In local standalone the
+controller may prune the shared list further after registry boot; in split
+topologies the API advertises its own merge result (not controller process
+memory).
+
 **Usage:**
 
 ```shell

services/intake/src/nmp/intake/spans/ingest/atif_domain.py

@@ -155,6 +155,7 @@ class AtifStepBase(BaseModel):
     is_copied_context: bool | None = None
     extra: dict[str, Any] | None = None
     llm_call_count: int | None = Field(default=None, ge=0)
+    observation: AtifObservation | None = None
 
     model_config = ConfigDict(extra="forbid")
 
@@ -184,7 +185,6 @@ class AtifStepAgent(AtifStepBase):
     reasoning_effort: str | float | None = None
     reasoning_content: str | None = None
     tool_calls: list[AtifToolCall] | None = None
-    observation: AtifObservation | None = None
     metrics: AtifMetrics | None = None
 
 
@@ -209,10 +209,9 @@ def validate_atif_step_ids(steps: list[AtifStep]) -> None:
 def validate_atif_tool_call_references(steps: list[AtifStep]) -> None:
     """Require unique calls and resolvable observation call references."""
     for step in steps:
-        if not isinstance(step, AtifStepAgent):
-            continue
         tool_call_ids: set[str] = set()
-        for tool_call in step.tool_calls or []:
+        tool_calls = step.tool_calls if isinstance(step, AtifStepAgent) else None
+        for tool_call in tool_calls or []:
             if tool_call.tool_call_id in tool_call_ids:
                 raise ValueError(f"Duplicate tool_call_id '{tool_call.tool_call_id}' in step {step.step_id}")
             tool_call_ids.add(tool_call.tool_call_id)
@@ -229,7 +228,7 @@ def validate_atif_tool_call_references(steps: list[AtifStep]) -> None:
 def validate_atif_v17_subagent_ref_resolution_keys(steps: list[AtifStep]) -> None:
     """Require v1.7 subagent references to include a resolvable key."""
     for step in steps:
-        if not isinstance(step, AtifStepAgent) or step.observation is None:
+        if step.observation is None:
             continue
         for result in step.observation.results:
             for subagent_ref in result.subagent_trajectory_ref or []:

services/intake/src/nmp/intake/spans/ingest/atif_mapping.py

@@ -844,8 +844,8 @@ def _step_tool_calls(step: AtifStep) -> list[AtifToolCall]:
 
 
 def _step_observation(step: AtifStep) -> AtifObservation | None:
-    """Return the observation attached to an agent step."""
-    return step.observation if isinstance(step, AtifStepAgent) else None
+    """Return the observation attached to any step."""
+    return step.observation
 
 
 def _observation_result_for_tool_call(step: AtifStep, tool_call_id: str) -> AtifObservationResult | None: