diff --git a/skills/integrations/consumer/nemo-fabric-integrate/SKILL.md b/skills/integrations/consumer/nemo-fabric-integrate/SKILL.md index b3bdf5c06..c1c34edf9 100644 --- a/skills/integrations/consumer/nemo-fabric-integrate/SKILL.md +++ b/skills/integrations/consumer/nemo-fabric-integrate/SKILL.md @@ -158,12 +158,13 @@ Pick the smallest lifecycle the consumer needs: failures remain normalized `RunResult` values. If iteration stops early, call `await stream.aclose()` before starting another turn. `aclose()` waits for the turn to finish; it does not cancel the harness invocation. The SDK - intentionally exposes ATOF records generated by NeMo Relay only; adapter-native progressive - output is deferred to a future normalized NeMo Fabric contract. The listener + intentionally exposes only ATOF records generated by NeMo Relay. A future + normalized NeMo Fabric contract will address adapter-native progressive + output. The listener limits each record to 1 MiB and its queue to 1,024 records or 16 MiB of encoded data. It correlates records through the NeMo Fabric request ID for - in-process harnesses or NeMo Relay's turn-scope role and 1-based turn index for - gateway harnesses, then yields only the matched scope tree. Delayed + in-process harnesses. For gateway harnesses, it uses the NeMo Relay turn-scope + role and 1-based turn index. It yields only the matched scope tree. Delayed prior-turn records therefore do not enter the next stream. If gateway and NeMo Fabric turn sequences do not align, the SDK discards the uncorrelated records and emits a `RuntimeWarning` after natural stream exhaustion. The listener