nv_ingest.framework.orchestration.ray.primitives package#

Submodules#

nv_ingest.framework.orchestration.ray.primitives.dataclasses module#

nv_ingest.framework.orchestration.ray.primitives.pipeline_monitor module#

class nv_ingest.framework.orchestration.ray.primitives.pipeline_monitor.DisplayConfig(use_gui: bool = False)[source]#

Bases: object

Configuration for monitoring display.

use_gui: bool = False#
class nv_ingest.framework.orchestration.ray.primitives.pipeline_monitor.MonitorConfig(
use_gui: bool = False,
poll_interval: float = 5.0,
use_console: bool = True,
)[source]#

Bases: object

Configuration specific to the PipelineMonitor.

poll_interval: float = 5.0#
use_console: bool = True#
use_gui: bool = False#
class nv_ingest.framework.orchestration.ray.primitives.pipeline_monitor.PipelineMonitor(
pipeline: Any,
config: MonitorConfig,
)[source]#

Bases: object

Monitors a RayPipeline instance and manages its display (GUI or Console).

Runs in a separate thread, periodically fetching data from the pipeline and updating the display based on its own configuration. Decoupled from the RayPipeline lifecycle.

start() → None[source]#

Starts the monitoring thread and display.

stop() → None[source]#

Stops the monitoring thread and cleans up the display.

nv_ingest.framework.orchestration.ray.primitives.pipeline_topology module#

nv_ingest.framework.orchestration.ray.primitives.ray_pipeline module#

nv_ingest.framework.orchestration.ray.primitives.ray_stat_collector module#

Module contents#