nv_dfm_core.session: Session and Job Management

Session

The main entry point for connecting to a federation and executing pipelines.

Session	Main entry point for executing DFM pipelines in a federation.
SessionDelegate	Abstract base class for session delegates that handle different execution targets.

Jobs

Job	A Job object is returned by Session.execute() and provides a way to interact with the running job.
JobStatus	Enumeration of possible job execution states.

Callbacks

DFM delivers pipeline results to your application through callbacks. The callback types and dispatcher strategies below control how and when callbacks are invoked.

DfmDataCallback
DfmDataCallbackSync
DfmDataCallbackAsync
CallbackDispatcher	Factory for creating CallbackRunner instances.
DirectDispatcher	Default dispatcher: calls callbacks immediately from the background thread.
ManualDispatcher	Dispatcher that queues tokens for manual processing.
AsyncioDispatcher	Dispatcher that schedules callbacks on an asyncio event loop.
CallbackRunner	Executes callbacks for a specific job.
ManualCallbackRunner	Runner that queues tokens for manual processing.

callbacks_kind	Determine whether all callbacks are sync, all are async, or none provided.
call_callbacks	Call sync callbacks for the given tokens.
call_callbacks_async	Call async callbacks for the given tokens.
configure_session_logging	Configure logging for DFM Session based on environment variables.