nv_dfm_core.session.CallbackDispatcher#

class nv_dfm_core.session.CallbackDispatcher[source]#

Factory for creating CallbackRunner instances.

Set on Session to control how callbacks are invoked across all jobs. Each dispatcher implementation provides a different strategy for where and when callbacks are executed (e.g., directly, queued, on event loop).

abstractmethod create_runner(default_callback=None, place_callbacks=None)[source]#

Create a new CallbackRunner bound to the given callbacks.

Parameters:

  • default_callback (DfmDataCallback | None) – Fallback callback for tokens without a place-specific callback.

  • place_callbacks (dict[str, DfmDataCallback] | None) – Dictionary mapping place names to callbacks.

Returns:

A new CallbackRunner instance configured for this dispatcher’s strategy.

Return type:

CallbackRunner