nv_ingest.framework.orchestration.ray package

Subpackages

• nv_ingest.framework.orchestration.ray.edges package
  • Submodules
  • nv_ingest.framework.orchestration.ray.edges.async_queue_edge module
  • nv_ingest.framework.orchestration.ray.edges.ray_queue_edge module
  • nv_ingest.framework.orchestration.ray.edges.threaded_queue_edge module
  • Module contents
• nv_ingest.framework.orchestration.ray.examples package
  • Submodules
  • nv_ingest.framework.orchestration.ray.examples.pipeline_test_harness module
  • nv_ingest.framework.orchestration.ray.examples.task_source_harness module
  • nv_ingest.framework.orchestration.ray.examples.task_source_sink_harness module
  • Module contents
• 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
    • DisplayConfig
      • use_gui
    • MonitorConfig
      • poll_interval
      • use_console
      • use_gui
    • PipelineMonitor
      • start()
      • stop()
  • 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
• nv_ingest.framework.orchestration.ray.stages package
  • Subpackages
    • nv_ingest.framework.orchestration.ray.stages.extractors package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.extractors.audio_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.chart_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.docx_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.image_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.infographic_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.pdf_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.pptx_extractor module
      • nv_ingest.framework.orchestration.ray.stages.extractors.table_extractor module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.injectors package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.injectors.metadata_injector module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.meta package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.meta.ray_actor_edge_base module
      • nv_ingest.framework.orchestration.ray.stages.meta.ray_actor_sink_stage_base module
      • nv_ingest.framework.orchestration.ray.stages.meta.ray_actor_source_stage_base module
      • nv_ingest.framework.orchestration.ray.stages.meta.ray_actor_stage_base module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.mutate package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.mutate.image_dedup module
      • nv_ingest.framework.orchestration.ray.stages.mutate.image_filter module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.sinks package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.sinks.default_drain module
      • nv_ingest.framework.orchestration.ray.stages.sinks.message_broker_task_sink module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.sources package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.sources.message_broker_task_source module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.storage package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.storage.image_storage module
      • nv_ingest.framework.orchestration.ray.stages.storage.store_embeddings module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.telemetry package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.telemetry.job_counter module
      • nv_ingest.framework.orchestration.ray.stages.telemetry.otel_meter module
      • nv_ingest.framework.orchestration.ray.stages.telemetry.otel_tracer module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.transforms package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.transforms.image_caption module
      • nv_ingest.framework.orchestration.ray.stages.transforms.text_embed module
      • nv_ingest.framework.orchestration.ray.stages.transforms.text_splitter module
      • Module contents
    • nv_ingest.framework.orchestration.ray.stages.utility package
      • Submodules
      • nv_ingest.framework.orchestration.ray.stages.utility.throughput_monitor module
      • Module contents
  • Module contents
• nv_ingest.framework.orchestration.ray.util package
  • Subpackages
    • nv_ingest.framework.orchestration.ray.util.pipeline package
      • Submodules
      • nv_ingest.framework.orchestration.ray.util.pipeline.pid_controller module
      • nv_ingest.framework.orchestration.ray.util.pipeline.pipeline_builders module
      • nv_ingest.framework.orchestration.ray.util.pipeline.pipeline_runners module
      • nv_ingest.framework.orchestration.ray.util.pipeline.stage_builders module
      • Module contents
    • nv_ingest.framework.orchestration.ray.util.system_tools package
      • Submodules
      • nv_ingest.framework.orchestration.ray.util.system_tools.memory module
      • nv_ingest.framework.orchestration.ray.util.system_tools.visualizers module
      • Module contents
  • Module contents

Module contents