nemo_flow.scope_local#

Scope-local middleware and subscriber registration.

These helpers mirror the global guardrails, intercepts, and subscribers modules, but the registrations apply only while the owning scope is active. When that scope is popped, the registrations are removed automatically.

Example:

import nemo_flow

def redact(tool_name, args):
    return {**args, "api_key": "***"}

with nemo_flow.scope.scope("request", nemo_flow.ScopeType.Agent) as handle:
    nemo_flow.scope_local.register_tool_sanitize_request(handle, "redact", 10, redact)

Functions#

`register_tool_sanitize_request`(scope_handle, name, ...)	Register a scope-local tool sanitize-request guardrail.
`deregister_tool_sanitize_request`(scope_handle, name)	Remove a scope-local tool sanitize-request guardrail.
`register_tool_sanitize_response`(scope_handle, name, ...)	Register a scope-local tool sanitize-response guardrail.
`deregister_tool_sanitize_response`(scope_handle, name)	Remove a scope-local tool sanitize-response guardrail.
`register_tool_conditional_execution`(scope_handle, ...)	Register a scope-local tool conditional-execution guardrail.
`deregister_tool_conditional_execution`(scope_handle, name)	Remove a scope-local tool conditional-execution guardrail.
`register_tool_request`(scope_handle, name, priority, ...)	Register a scope-local tool request intercept.
`deregister_tool_request`(scope_handle, name)	Remove a scope-local tool request intercept.
`register_tool_execution`(scope_handle, name, priority, fn)	Register scope-local middleware around tool execution.
`deregister_tool_execution`(scope_handle, name)	Remove a scope-local tool execution intercept.
`register_llm_sanitize_request`(scope_handle, name, ...)	Register a scope-local LLM sanitize-request guardrail.
`deregister_llm_sanitize_request`(scope_handle, name)	Remove a scope-local LLM sanitize-request guardrail.
`register_llm_sanitize_response`(scope_handle, name, ...)	Register a scope-local LLM sanitize-response guardrail.
`deregister_llm_sanitize_response`(scope_handle, name)	Remove a scope-local LLM sanitize-response guardrail.
`register_llm_conditional_execution`(scope_handle, name, ...)	Register a scope-local LLM conditional-execution guardrail.
`deregister_llm_conditional_execution`(scope_handle, name)	Remove a scope-local LLM conditional-execution guardrail.
`register_llm_request`(scope_handle, name, priority, ...)	Register a scope-local LLM request intercept.
`deregister_llm_request`(scope_handle, name)	Remove a scope-local LLM request intercept.
`register_llm_execution`(scope_handle, name, priority, fn)	Register scope-local middleware around non-streaming LLM execution.
`deregister_llm_execution`(scope_handle, name)	Remove a scope-local LLM execution intercept.
`register_llm_stream_execution`(scope_handle, name, ...)	Register scope-local middleware around streaming LLM execution.
`deregister_llm_stream_execution`(scope_handle, name)	Remove a scope-local streaming LLM execution intercept.
`register_subscriber`(scope_handle, name, callback)	Register an event subscriber that is active only for `scope_handle`.
`deregister_subscriber`(scope_handle, name)	Remove a scope-local event subscriber.

Module Contents#

nemo_flow.scope_local.register_tool_sanitize_request( scope_handle, name, priority, guardrail, )#

Register a scope-local tool sanitize-request guardrail.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique guardrail name within the owning scope.
priority – Execution order for the guardrail. Lower values run first.
guardrail – Callable invoked as guardrail(tool_name, args) that returns the sanitized payload recorded on emitted start events.

Returns:

This function returns after the scope-local guardrail is registered.

Return type:

None

Notes

As with the global variant, this sanitizes emitted event payloads only.

nemo_flow.scope_local.deregister_tool_sanitize_request(scope_handle, name)#

Remove a scope-local tool sanitize-request guardrail.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Guardrail name previously passed to register_tool_sanitize_request().

Returns:

True if a guardrail was removed, otherwise False.

Return type:

bool

Notes

Removing the guardrail early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_tool_sanitize_response( scope_handle, name, priority, guardrail, )#

Register a scope-local tool sanitize-response guardrail.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique guardrail name within the owning scope.
priority – Execution order for the guardrail. Lower values run first.
guardrail – Callable invoked as guardrail(tool_name, result) that returns the sanitized payload recorded on emitted end events.

Returns:

This function returns after the scope-local guardrail is registered.

Return type:

None

Notes

As with the global variant, this sanitizes emitted event payloads only.

nemo_flow.scope_local.deregister_tool_sanitize_response(scope_handle, name)#

Remove a scope-local tool sanitize-response guardrail.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Guardrail name previously passed to register_tool_sanitize_response().

Returns:

True if a guardrail was removed, otherwise False.

Return type:

bool

Notes

Removing the guardrail early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_tool_conditional_execution( scope_handle, name, priority, guardrail, )#

Register a scope-local tool conditional-execution guardrail.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique guardrail name within the owning scope.
priority – Execution order for the guardrail. Lower values run first.
guardrail – Callable invoked as guardrail(tool_name, args). Return None to allow execution or a rejection message to block it.

Returns:

This function returns after the scope-local guardrail is registered.

Return type:

None

Notes

Scope-local conditional guardrails run in addition to global conditional guardrails for calls emitted under the owning scope.

nemo_flow.scope_local.deregister_tool_conditional_execution(scope_handle, name)#

Remove a scope-local tool conditional-execution guardrail.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Guardrail name previously passed to register_tool_conditional_execution().

Returns:

True if a guardrail was removed, otherwise False.

Return type:

bool

Notes

Removing the guardrail early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_tool_request(scope_handle, name, priority, break_chain, fn)#

Register a scope-local tool request intercept.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique intercept name within the owning scope.
priority – Execution order for the intercept. Lower values run first.
break_chain – Whether to stop applying lower-priority request intercepts after this intercept runs.
fn – Callable invoked as fn(tool_name, args) that returns the rewritten tool arguments.

Returns:

This function returns after the scope-local intercept is registered.

Return type:

None

Notes

Scope-local request intercepts are merged with global intercepts using the same priority ordering rules.

nemo_flow.scope_local.deregister_tool_request(scope_handle, name)#

Remove a scope-local tool request intercept.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Intercept name previously passed to register_tool_request().

Returns:

True if an intercept was removed, otherwise False.

Return type:

bool

Notes

Removing the intercept early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_tool_execution(scope_handle, name, priority, fn)#

Register scope-local middleware around tool execution.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique intercept name within the owning scope.
priority – Execution order for the intercept. Lower values run first.
fn – Callable invoked as fn(tool_name, args, next_call). It may call next_call(args) to continue execution, modify the result, or short-circuit the tool call entirely.

Returns:

This function returns after the scope-local intercept is registered.

Return type:

None

Notes

Execution intercepts wrap only calls emitted while the owning scope remains active.

nemo_flow.scope_local.deregister_tool_execution(scope_handle, name)#

Remove a scope-local tool execution intercept.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Intercept name previously passed to register_tool_execution().

Returns:

True if an intercept was removed, otherwise False.

Return type:

bool

Notes

Removing the intercept early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_llm_sanitize_request(scope_handle, name, priority, guardrail)#

Register a scope-local LLM sanitize-request guardrail.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique guardrail name within the owning scope.
priority – Execution order for the guardrail. Lower values run first.
guardrail – Callable invoked as guardrail(request) that returns the sanitized request recorded on emitted start events.

Returns:

This function returns after the scope-local guardrail is registered.

Return type:

None

Notes

As with the global variant, this sanitizes emitted event payloads only.

nemo_flow.scope_local.deregister_llm_sanitize_request(scope_handle, name)#

Remove a scope-local LLM sanitize-request guardrail.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Guardrail name previously passed to register_llm_sanitize_request().

Returns:

True if a guardrail was removed, otherwise False.

Return type:

bool

Notes

Removing the guardrail early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_llm_sanitize_response( scope_handle, name, priority, guardrail, )#

Register a scope-local LLM sanitize-response guardrail.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique guardrail name within the owning scope.
priority – Execution order for the guardrail. Lower values run first.
guardrail – Callable invoked as guardrail(response) that returns the sanitized payload recorded on emitted end events.

Returns:

This function returns after the scope-local guardrail is registered.

Return type:

None

Notes

As with the global variant, this sanitizes emitted event payloads only.

nemo_flow.scope_local.deregister_llm_sanitize_response(scope_handle, name)#

Remove a scope-local LLM sanitize-response guardrail.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Guardrail name previously passed to register_llm_sanitize_response().

Returns:

True if a guardrail was removed, otherwise False.

Return type:

bool

Notes

Removing the guardrail early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_llm_conditional_execution( scope_handle, name, priority, guardrail, )#

Register a scope-local LLM conditional-execution guardrail.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique guardrail name within the owning scope.
priority – Execution order for the guardrail. Lower values run first.
guardrail – Callable invoked as guardrail(request). Return None to allow execution or a rejection message to block it.

Returns:

This function returns after the scope-local guardrail is registered.

Return type:

None

Notes

Scope-local conditional guardrails run in addition to global conditional guardrails for calls emitted under the owning scope.

nemo_flow.scope_local.deregister_llm_conditional_execution(scope_handle, name)#

Remove a scope-local LLM conditional-execution guardrail.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Guardrail name previously passed to register_llm_conditional_execution().

Returns:

True if a guardrail was removed, otherwise False.

Return type:

bool

Notes

Removing the guardrail early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_llm_request(scope_handle, name, priority, break_chain, fn)#

Register a scope-local LLM request intercept.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique intercept name within the owning scope.
priority – Execution order for the intercept. Lower values run first.
break_chain – Whether to stop applying lower-priority request intercepts after this intercept runs.
fn – Callable invoked as fn(name, request, annotated) that returns a tuple of (request, annotated) for the next stage.

Returns:

This function returns after the scope-local intercept is registered.

Return type:

None

Notes

Scope-local request intercepts are merged with global intercepts using the same priority ordering rules.

nemo_flow.scope_local.deregister_llm_request(scope_handle, name)#

Remove a scope-local LLM request intercept.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Intercept name previously passed to register_llm_request().

Returns:

True if an intercept was removed, otherwise False.

Return type:

bool

Notes

Removing the intercept early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_llm_execution(scope_handle, name, priority, fn)#

Register scope-local middleware around non-streaming LLM execution.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique intercept name within the owning scope.
priority – Execution order for the intercept. Lower values run first.
fn – Callable invoked as fn(name, request, next_call) that may call next_call(request) to continue execution or short-circuit it.

Returns:

This function returns after the scope-local intercept is registered.

Return type:

None

Notes

Execution intercepts wrap only calls emitted while the owning scope remains active.

nemo_flow.scope_local.deregister_llm_execution(scope_handle, name)#

Remove a scope-local LLM execution intercept.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Intercept name previously passed to register_llm_execution().

Returns:

True if an intercept was removed, otherwise False.

Return type:

bool

Notes

Removing the intercept early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_llm_stream_execution(scope_handle, name, priority, fn)#

Register scope-local middleware around streaming LLM execution.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique intercept name within the owning scope.
priority – Execution order for the intercept. Lower values run first.
fn – Callable invoked as fn(request, next_call) that returns an async iterator of chunks, either by delegating to next_call or by replacing the stream entirely.

Returns:

This function returns after the scope-local intercept is registered.

Return type:

None

Notes

Streaming execution intercepts wrap chunk production only. They do not replace the collector or finalizer callbacks.

nemo_flow.scope_local.deregister_llm_stream_execution(scope_handle, name)#

Remove a scope-local streaming LLM execution intercept.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Intercept name previously passed to register_llm_stream_execution().

Returns:

True if an intercept was removed, otherwise False.

Return type:

bool

Notes

Removing the intercept early affects only future work in the owning scope. Popping the scope would also remove it automatically.

nemo_flow.scope_local.register_subscriber(scope_handle, name, callback)#

Register an event subscriber that is active only for scope_handle.

Parameters:

scope_handle – Owning scope handle. The registration is removed when this scope is popped.
name – Unique subscriber name within the owning scope.
callback – Callable invoked as callback(event) for each lifecycle event emitted while the scope remains active.

Returns:

This function returns after the scope-local subscriber is registered.

Return type:

None

Notes

The subscriber observes only events emitted while the owning scope remains active.

Example:

import nemo_flow

def log_event(event):
    print(event.kind, event.name)

with nemo_flow.scope.scope("request", nemo_flow.ScopeType.Agent) as handle:
    nemo_flow.scope_local.register_subscriber(handle, "logger", log_event)

nemo_flow.scope_local.deregister_subscriber(scope_handle, name)#

Remove a scope-local event subscriber.

Parameters:

scope_handle – Scope handle that owns the registration.
name – Subscriber name previously passed to register_subscriber().

Returns:

True if a subscriber was removed, otherwise False.

Return type:

bool

Notes

Removing the subscriber early affects only future event delivery in the owning scope. Popping the scope would also remove it automatically.