LICENSE
README.md
pyproject.toml
src/nemo_retriever/__init__.py
src/nemo_retriever/__main__.py
src/nemo_retriever/_build_info.py
src/nemo_retriever/version.py
src/nemo_retriever.egg-info/PKG-INFO
src/nemo_retriever.egg-info/SOURCES.txt
src/nemo_retriever.egg-info/dependency_links.txt
src/nemo_retriever.egg-info/entry_points.txt
src/nemo_retriever.egg-info/requires.txt
src/nemo_retriever.egg-info/top_level.txt
src/nemo_retriever/cli/__init__.py
src/nemo_retriever/cli/ingest_workflow.py
src/nemo_retriever/cli/main.py
src/nemo_retriever/cli/query_workflow.py
src/nemo_retriever/cli/audio/__init__.py
src/nemo_retriever/cli/audio/__main__.py
src/nemo_retriever/cli/audio/cli.py
src/nemo_retriever/cli/audio/stage.py
src/nemo_retriever/cli/chart/__init__.py
src/nemo_retriever/cli/chart/__main__.py
src/nemo_retriever/cli/chart/commands.py
src/nemo_retriever/cli/compare/__init__.py
src/nemo_retriever/cli/compare/__main__.py
src/nemo_retriever/cli/html/__init__.py
src/nemo_retriever/cli/html/__main__.py
src/nemo_retriever/cli/image/__init__.py
src/nemo_retriever/cli/image/__main__.py
src/nemo_retriever/cli/image/render.py
src/nemo_retriever/cli/infographic/__init__.py
src/nemo_retriever/cli/infographic/commands.py
src/nemo_retriever/cli/local/__init__.py
src/nemo_retriever/cli/local/__main__.py
src/nemo_retriever/cli/local/stages/__init__.py
src/nemo_retriever/cli/local/stages/stage1_pdf_extraction.py
src/nemo_retriever/cli/local/stages/stage5_text_embeddings.py
src/nemo_retriever/cli/local/stages/stage6_vdb_upload.py
src/nemo_retriever/cli/local/stages/stage7_vdb_query.py
src/nemo_retriever/cli/local/stages/stage999_post_mortem_analysis.py
src/nemo_retriever/cli/pdf/__init__.py
src/nemo_retriever/cli/pdf/__main__.py
src/nemo_retriever/cli/pdf/stage.py
src/nemo_retriever/cli/pipeline/__init__.py
src/nemo_retriever/cli/pipeline/__main__.py
src/nemo_retriever/cli/table/__init__.py
src/nemo_retriever/cli/table/commands.py
src/nemo_retriever/cli/text_embed/__init__.py
src/nemo_retriever/cli/text_embed/commands.py
src/nemo_retriever/cli/text_embed/stage.py
src/nemo_retriever/cli/txt/__init__.py
src/nemo_retriever/cli/txt/__main__.py
src/nemo_retriever/cli/video/__init__.py
src/nemo_retriever/cli/video/__main__.py
src/nemo_retriever/cli/video/cli.py
src/nemo_retriever/cli/video/stage.py
src/nemo_retriever/common/__init__.py
src/nemo_retriever/common/config_utils.py
src/nemo_retriever/common/detection_summary.py
src/nemo_retriever/common/input_files.py
src/nemo_retriever/common/nvtx.py
src/nemo_retriever/common/parquet_to_lancedb.py
src/nemo_retriever/common/policy.py
src/nemo_retriever/common/ray_resource_hueristics.py
src/nemo_retriever/common/remote_auth.py
src/nemo_retriever/common/api/__init__.py
src/nemo_retriever/common/api/internal/__init__.py
src/nemo_retriever/common/api/internal/enums/__init__.py
src/nemo_retriever/common/api/internal/enums/common.py
src/nemo_retriever/common/api/internal/extract/__init__.py
src/nemo_retriever/common/api/internal/extract/image/__init__.py
src/nemo_retriever/common/api/internal/extract/image/chart_extractor.py
src/nemo_retriever/common/api/internal/extract/image/infographic_extractor.py
src/nemo_retriever/common/api/internal/extract/image/table_extractor.py
src/nemo_retriever/common/api/internal/extract/pdf/__init__.py
src/nemo_retriever/common/api/internal/extract/pdf/pdf_extractor.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/__init__.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/adobe.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/llama.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/nemotron_parse.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/pdfium.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/tika.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/unstructured_io.py
src/nemo_retriever/common/api/internal/extract/pdf/engines/pdf_helpers/__init__.py
src/nemo_retriever/common/api/internal/mutate/__init__.py
src/nemo_retriever/common/api/internal/mutate/deduplicate.py
src/nemo_retriever/common/api/internal/primitives/__init__.py
src/nemo_retriever/common/api/internal/primitives/control_message_task.py
src/nemo_retriever/common/api/internal/primitives/ingest_control_message.py
src/nemo_retriever/common/api/internal/primitives/tracing/__init__.py
src/nemo_retriever/common/api/internal/primitives/tracing/logging.py
src/nemo_retriever/common/api/internal/primitives/tracing/tagging.py
src/nemo_retriever/common/api/internal/schemas/__init__.py
src/nemo_retriever/common/api/internal/schemas/mixins.py
src/nemo_retriever/common/api/internal/schemas/extract/__init__.py
src/nemo_retriever/common/api/internal/schemas/extract/extract_chart_schema.py
src/nemo_retriever/common/api/internal/schemas/extract/extract_infographic_schema.py
src/nemo_retriever/common/api/internal/schemas/extract/extract_pdf_schema.py
src/nemo_retriever/common/api/internal/schemas/extract/extract_table_schema.py
src/nemo_retriever/common/api/internal/schemas/meta/__init__.py
src/nemo_retriever/common/api/internal/schemas/meta/base_model_noext.py
src/nemo_retriever/common/api/internal/schemas/meta/ingest_job_schema.py
src/nemo_retriever/common/api/internal/schemas/meta/metadata_schema.py
src/nemo_retriever/common/api/internal/schemas/mutate/__init__.py
src/nemo_retriever/common/api/internal/schemas/mutate/mutate_image_dedup_schema.py
src/nemo_retriever/common/api/internal/schemas/transform/__init__.py
src/nemo_retriever/common/api/internal/schemas/transform/transform_text_embedding_schema.py
src/nemo_retriever/common/api/internal/transform/__init__.py
src/nemo_retriever/common/api/internal/transform/embed_text.py
src/nemo_retriever/common/api/util/__init__.py
src/nemo_retriever/common/api/util/control_message/__init__.py
src/nemo_retriever/common/api/util/control_message/validators.py
src/nemo_retriever/common/api/util/converters/__init__.py
src/nemo_retriever/common/api/util/converters/bytetools.py
src/nemo_retriever/common/api/util/converters/datetools.py
src/nemo_retriever/common/api/util/detectors/__init__.py
src/nemo_retriever/common/api/util/detectors/language.py
src/nemo_retriever/common/api/util/exception_handlers/__init__.py
src/nemo_retriever/common/api/util/exception_handlers/converters.py
src/nemo_retriever/common/api/util/exception_handlers/decorators.py
src/nemo_retriever/common/api/util/exception_handlers/detectors.py
src/nemo_retriever/common/api/util/exception_handlers/pdf.py
src/nemo_retriever/common/api/util/image_processing/__init__.py
src/nemo_retriever/common/api/util/image_processing/clustering.py
src/nemo_retriever/common/api/util/image_processing/table_and_chart.py
src/nemo_retriever/common/api/util/image_processing/transforms.py
src/nemo_retriever/common/api/util/logging/__init__.py
src/nemo_retriever/common/api/util/logging/configuration.py
src/nemo_retriever/common/api/util/logging/sanitize.py
src/nemo_retriever/common/api/util/metadata/__init__.py
src/nemo_retriever/common/api/util/metadata/aggregators.py
src/nemo_retriever/common/api/util/pdf/__init__.py
src/nemo_retriever/common/api/util/pdf/pdfium.py
src/nemo_retriever/common/api/util/string_processing/__init__.py
src/nemo_retriever/common/io/__init__.py
src/nemo_retriever/common/io/dataframe.py
src/nemo_retriever/common/io/export.py
src/nemo_retriever/common/io/image_store.py
src/nemo_retriever/common/io/markdown.py
src/nemo_retriever/common/io/stage_files.py
src/nemo_retriever/common/modality/__init__.py
src/nemo_retriever/common/modality/content_transforms.py
src/nemo_retriever/common/modality/table_and_chart.py
src/nemo_retriever/common/modality/audio/__init__.py
src/nemo_retriever/common/modality/audio/media_interface.py
src/nemo_retriever/common/modality/caption/__init__.py
src/nemo_retriever/common/modality/caption/model_profiles.py
src/nemo_retriever/common/modality/chart/__init__.py
src/nemo_retriever/common/modality/chart/config.py
src/nemo_retriever/common/modality/chart/processor.py
src/nemo_retriever/common/modality/chart/shared.py
src/nemo_retriever/common/modality/convert/__init__.py
src/nemo_retriever/common/modality/convert/to_pdf.py
src/nemo_retriever/common/modality/html/__init__.py
src/nemo_retriever/common/modality/html/convert.py
src/nemo_retriever/common/modality/image/__init__.py
src/nemo_retriever/common/modality/image/load.py
src/nemo_retriever/common/modality/infographic/__init__.py
src/nemo_retriever/common/modality/infographic/config.py
src/nemo_retriever/common/modality/infographic/infographic_detection.py
src/nemo_retriever/common/modality/infographic/processor.py
src/nemo_retriever/common/modality/ocr/__init__.py
src/nemo_retriever/common/modality/ocr/config.py
src/nemo_retriever/common/modality/ocr/shared.py
src/nemo_retriever/common/modality/page_elements/__init__.py
src/nemo_retriever/common/modality/page_elements/local.py
src/nemo_retriever/common/modality/page_elements/shared.py
src/nemo_retriever/common/modality/parse/__init__.py
src/nemo_retriever/common/modality/parse/nemotron_parse_postprocessing.py
src/nemo_retriever/common/modality/pdf/__init__.py
src/nemo_retriever/common/modality/pdf/config.py
src/nemo_retriever/common/modality/pdf/io.py
src/nemo_retriever/common/modality/pipeline/__init__.py
src/nemo_retriever/common/modality/pipeline/content.py
src/nemo_retriever/common/modality/pipeline/embedding.py
src/nemo_retriever/common/modality/table/__init__.py
src/nemo_retriever/common/modality/table/config.py
src/nemo_retriever/common/modality/table/processor.py
src/nemo_retriever/common/modality/table/shared.py
src/nemo_retriever/common/modality/txt/__init__.py
src/nemo_retriever/common/modality/txt/split.py
src/nemo_retriever/common/modality/video/__init__.py
src/nemo_retriever/common/modality/video/_content_types.py
src/nemo_retriever/common/params/__init__.py
src/nemo_retriever/common/params/chunk_bundle.py
src/nemo_retriever/common/params/models.py
src/nemo_retriever/common/params/utils.py
src/nemo_retriever/common/schemas/__init__.py
src/nemo_retriever/common/schemas/base.py
src/nemo_retriever/common/schemas/document.py
src/nemo_retriever/common/schemas/job.py
src/nemo_retriever/common/schemas/pipeline_spec.py
src/nemo_retriever/common/schemas/requests.py
src/nemo_retriever/common/schemas/responses.py
src/nemo_retriever/common/vdb/__init__.py
src/nemo_retriever/common/vdb/adt_vdb.py
src/nemo_retriever/common/vdb/factory.py
src/nemo_retriever/common/vdb/lancedb.py
src/nemo_retriever/common/vdb/lancedb_bulk.py
src/nemo_retriever/common/vdb/lancedb_read.py
src/nemo_retriever/common/vdb/lancedb_schema.py
src/nemo_retriever/common/vdb/records.py
src/nemo_retriever/common/vdb/sidecar_metadata.py
src/nemo_retriever/common/vdb/stage.py
src/nemo_retriever/examples/common.py
src/nemo_retriever/examples/graph_pipeline.py
src/nemo_retriever/graph/__init__.py
src/nemo_retriever/graph/designer.py
src/nemo_retriever/graph/executor.py
src/nemo_retriever/graph/graph_pipeline_registry.py
src/nemo_retriever/graph/ingestor_runtime.py
src/nemo_retriever/graph/operator_resolution.py
src/nemo_retriever/graph/pipeline_graph.py
src/nemo_retriever/graph/retriever.py
src/nemo_retriever/graph/retriever_utils.py
src/nemo_retriever/graph/stages/__init__.py
src/nemo_retriever/graph/stages/build_plan.py
src/nemo_retriever/graph/stages/contracts.py
src/nemo_retriever/graph/stages/run_plan.py
src/nemo_retriever/graph/stages/stage_registry.py
src/nemo_retriever/harness/__init__.py
src/nemo_retriever/harness/__main__.py
src/nemo_retriever/harness/artifacts.py
src/nemo_retriever/harness/cli.py
src/nemo_retriever/harness/config.py
src/nemo_retriever/harness/helm_manager.py
src/nemo_retriever/harness/history.py
src/nemo_retriever/harness/nightly.py
src/nemo_retriever/harness/parsers.py
src/nemo_retriever/harness/reporting.py
src/nemo_retriever/harness/run.py
src/nemo_retriever/harness/runner.py
src/nemo_retriever/harness/scheduler.py
src/nemo_retriever/harness/slack.py
src/nemo_retriever/harness/portal/__init__.py
src/nemo_retriever/harness/portal/app.py
src/nemo_retriever/harness/portal/mcp_registry.py
src/nemo_retriever/harness/portal/mcp_server.py
src/nemo_retriever/harness/portal/mcp_tools.py
src/nemo_retriever/harness/portal/static/index.html
src/nemo_retriever/harness/portal/static/nvidia-logo.svg
src/nemo_retriever/harness/portal/static/views/alerts.jsx
src/nemo_retriever/harness/portal/static/views/analytics.jsx
src/nemo_retriever/harness/portal/static/views/app.jsx
src/nemo_retriever/harness/portal/static/views/database.jsx
src/nemo_retriever/harness/portal/static/views/datasets.jsx
src/nemo_retriever/harness/portal/static/views/designer.jsx
src/nemo_retriever/harness/portal/static/views/icons.jsx
src/nemo_retriever/harness/portal/static/views/ingestion.jsx
src/nemo_retriever/harness/portal/static/views/layout.jsx
src/nemo_retriever/harness/portal/static/views/log-viewer.jsx
src/nemo_retriever/harness/portal/static/views/mcp.jsx
src/nemo_retriever/harness/portal/static/views/models.jsx
src/nemo_retriever/harness/portal/static/views/presets.jsx
src/nemo_retriever/harness/portal/static/views/reporting.jsx
src/nemo_retriever/harness/portal/static/views/retrieval.jsx
src/nemo_retriever/harness/portal/static/views/run-detail.jsx
src/nemo_retriever/harness/portal/static/views/runners.jsx
src/nemo_retriever/harness/portal/static/views/runs.jsx
src/nemo_retriever/harness/portal/static/views/scheduling.jsx
src/nemo_retriever/harness/portal/static/views/settings.jsx
src/nemo_retriever/harness/portal/static/views/trigger.jsx
src/nemo_retriever/harness/portal/static/views/utils.jsx
src/nemo_retriever/ingest/__init__.py
src/nemo_retriever/ingest/execution.py
src/nemo_retriever/ingest/plan.py
src/nemo_retriever/ingestor/__init__.py
src/nemo_retriever/ingestor/branch_extraction.py
src/nemo_retriever/ingestor/config.py
src/nemo_retriever/ingestor/core.py
src/nemo_retriever/ingestor/graph_ingestor.py
src/nemo_retriever/ingestor/manifest.py
src/nemo_retriever/ingestor/plans.py
src/nemo_retriever/ingestor/results.py
src/nemo_retriever/models/__init__.py
src/nemo_retriever/models/hf_cache.py
src/nemo_retriever/models/hf_model_registry.py
src/nemo_retriever/models/model.py
src/nemo_retriever/models/inference/__init__.py
src/nemo_retriever/models/inference/config.py
src/nemo_retriever/models/inference/main_text_embed.py
src/nemo_retriever/models/inference/processor.py
src/nemo_retriever/models/inference/runtime.py
src/nemo_retriever/models/inference/shared.py
src/nemo_retriever/models/inference/vllm.py
src/nemo_retriever/models/llm/__init__.py
src/nemo_retriever/models/llm/text_utils.py
src/nemo_retriever/models/llm/types.py
src/nemo_retriever/models/llm/clients/__init__.py
src/nemo_retriever/models/llm/clients/judge.py
src/nemo_retriever/models/llm/clients/litellm.py
src/nemo_retriever/models/local/__init__.py
src/nemo_retriever/models/local/llama_nemotron_embed_1b_v2_embedder.py
src/nemo_retriever/models/local/llama_nemotron_embed_1b_v2_hf_embedder.py
src/nemo_retriever/models/local/llama_nemotron_embed_vl_1b_v2_embedder.py
src/nemo_retriever/models/local/nemotron_graphic_elements_v1.py
src/nemo_retriever/models/local/nemotron_ocr_v1.py
src/nemo_retriever/models/local/nemotron_ocr_v2.py
src/nemo_retriever/models/local/nemotron_page_elements_v3.py
src/nemo_retriever/models/local/nemotron_parse_v1_2.py
src/nemo_retriever/models/local/nemotron_rerank_v2.py
src/nemo_retriever/models/local/nemotron_rerank_vl_v2.py
src/nemo_retriever/models/local/nemotron_rerank_vl_v2_hf.py
src/nemo_retriever/models/local/nemotron_table_structure_v1.py
src/nemo_retriever/models/local/nemotron_vlm_captioner.py
src/nemo_retriever/models/local/parakeet_ctc_1_1b_asr.py
src/nemo_retriever/models/nim/__init__.py
src/nemo_retriever/models/nim/chat_completions.py
src/nemo_retriever/models/nim/error_reporter.py
src/nemo_retriever/models/nim/nim.py
src/nemo_retriever/models/nim/probe.py
src/nemo_retriever/models/nim/primitives/__init__.py
src/nemo_retriever/models/nim/primitives/default_values.py
src/nemo_retriever/models/nim/primitives/nim_client.py
src/nemo_retriever/models/nim/primitives/nim_model_interface.py
src/nemo_retriever/models/nim/primitives/model_interface/__init__.py
src/nemo_retriever/models/nim/primitives/model_interface/decorators.py
src/nemo_retriever/models/nim/primitives/model_interface/helpers.py
src/nemo_retriever/models/nim/primitives/model_interface/nemotron_parse.py
src/nemo_retriever/models/nim/primitives/model_interface/ocr.py
src/nemo_retriever/models/nim/primitives/model_interface/parakeet.py
src/nemo_retriever/models/nim/primitives/model_interface/text_embedding.py
src/nemo_retriever/models/nim/primitives/model_interface/vlm.py
src/nemo_retriever/models/nim/primitives/model_interface/yolox.py
src/nemo_retriever/models/nim/util/__init__.py
src/nemo_retriever/operators/__init__.py
src/nemo_retriever/operators/abstract_operator.py
src/nemo_retriever/operators/base.py
src/nemo_retriever/operators/content.py
src/nemo_retriever/operators/cpu_operator.py
src/nemo_retriever/operators/dedup.py
src/nemo_retriever/operators/embedding.py
src/nemo_retriever/operators/gpu_operator.py
src/nemo_retriever/operators/operator_archetype.py
src/nemo_retriever/operators/rerank.py
src/nemo_retriever/operators/vdb.py
src/nemo_retriever/operators/embed/__init__.py
src/nemo_retriever/operators/embed/cpu_operator.py
src/nemo_retriever/operators/embed/gpu_operator.py
src/nemo_retriever/operators/embed/operators.py
src/nemo_retriever/operators/embed/text_embed.py
src/nemo_retriever/operators/extract/__init__.py
src/nemo_retriever/operators/extract/audio/__init__.py
src/nemo_retriever/operators/extract/audio/asr_actor.py
src/nemo_retriever/operators/extract/audio/chunk_actor.py
src/nemo_retriever/operators/extract/audio/cpu_actor.py
src/nemo_retriever/operators/extract/audio/gpu_actor.py
src/nemo_retriever/operators/extract/caption/__init__.py
src/nemo_retriever/operators/extract/caption/caption.py
src/nemo_retriever/operators/extract/chart/__init__.py
src/nemo_retriever/operators/extract/chart/chart_detection.py
src/nemo_retriever/operators/extract/chart/cpu_actor.py
src/nemo_retriever/operators/extract/chart/gpu_actor.py
src/nemo_retriever/operators/extract/html/__init__.py
src/nemo_retriever/operators/extract/html/ray_data.py
src/nemo_retriever/operators/extract/image/__init__.py
src/nemo_retriever/operators/extract/image/ray_data.py
src/nemo_retriever/operators/extract/ocr/__init__.py
src/nemo_retriever/operators/extract/ocr/cpu_ocr.py
src/nemo_retriever/operators/extract/ocr/cpu_parse.py
src/nemo_retriever/operators/extract/ocr/gpu_ocr.py
src/nemo_retriever/operators/extract/ocr/gpu_parse.py
src/nemo_retriever/operators/extract/ocr/ocr.py
src/nemo_retriever/operators/extract/page_elements/__init__.py
src/nemo_retriever/operators/extract/page_elements/cpu_actor.py
src/nemo_retriever/operators/extract/page_elements/gpu_actor.py
src/nemo_retriever/operators/extract/page_elements/page_elements.py
src/nemo_retriever/operators/extract/parse/__init__.py
src/nemo_retriever/operators/extract/parse/nemotron_parse.py
src/nemo_retriever/operators/extract/pdf/__init__.py
src/nemo_retriever/operators/extract/pdf/extract.py
src/nemo_retriever/operators/extract/pdf/split.py
src/nemo_retriever/operators/extract/table/__init__.py
src/nemo_retriever/operators/extract/table/cpu_actor.py
src/nemo_retriever/operators/extract/table/gpu_actor.py
src/nemo_retriever/operators/extract/table/table_detection.py
src/nemo_retriever/operators/extract/txt/__init__.py
src/nemo_retriever/operators/extract/txt/ray_data.py
src/nemo_retriever/operators/extract/video/__init__.py
src/nemo_retriever/operators/extract/video/audio_visual_fuser.py
src/nemo_retriever/operators/extract/video/frame_actor.py
src/nemo_retriever/operators/extract/video/ocr_actor.py
src/nemo_retriever/operators/extract/video/split.py
src/nemo_retriever/operators/extract/video/text_dedup.py
src/nemo_retriever/operators/graph_ops/__init__.py
src/nemo_retriever/operators/graph_ops/content_operators.py
src/nemo_retriever/operators/graph_ops/custom_operator.py
src/nemo_retriever/operators/graph_ops/eval_operator.py
src/nemo_retriever/operators/graph_ops/file_loader_operator.py
src/nemo_retriever/operators/graph_ops/lancedb_write_operator.py
src/nemo_retriever/operators/graph_ops/multi_type_extract_operator.py
src/nemo_retriever/operators/graph_ops/react_agent_operator.py
src/nemo_retriever/operators/graph_ops/rrf_aggregator_operator.py
src/nemo_retriever/operators/graph_ops/scoring_operator.py
src/nemo_retriever/operators/graph_ops/selection_agent_operator.py
src/nemo_retriever/operators/graph_ops/store_operator.py
src/nemo_retriever/operators/graph_ops/subquery_operator.py
src/nemo_retriever/operators/graph_ops/webhook_operator.py
src/nemo_retriever/query/__init__.py
src/nemo_retriever/query/options.py
src/nemo_retriever/query/workflow.py
src/nemo_retriever/service/__init__.py
src/nemo_retriever/service/app.py
src/nemo_retriever/service/auth.py
src/nemo_retriever/service/cli.py
src/nemo_retriever/service/client.py
src/nemo_retriever/service/config.py
src/nemo_retriever/service/retriever-service.yaml
src/nemo_retriever/service/service_ingestor.py
src/nemo_retriever/service/vectordb_app.py
src/nemo_retriever/service/routers/__init__.py
src/nemo_retriever/service/routers/admin.py
src/nemo_retriever/service/routers/dashboard.py
src/nemo_retriever/service/routers/ingest.py
src/nemo_retriever/service/routers/metrics.py
src/nemo_retriever/service/services/__init__.py
src/nemo_retriever/service/services/event_bus.py
src/nemo_retriever/service/services/job_tracker.py
src/nemo_retriever/service/services/metrics.py
src/nemo_retriever/service/services/pipeline_executor.py
src/nemo_retriever/service/services/pipeline_pool.py
src/nemo_retriever/service/services/prometheus.py
src/nemo_retriever/service/services/proxy.py
src/nemo_retriever/service/services/sidecar_store.py
src/nemo_retriever/service/services/worker_result_store.py
src/nemo_retriever/service/utils/__init__.py
src/nemo_retriever/service/utils/file_type.py
src/nemo_retriever/tabular_data/__init__.py
src/nemo_retriever/tabular_data/sql_database.py
src/nemo_retriever/tabular_data/dev_tools/debug_ingest.py
src/nemo_retriever/tabular_data/dev_tools/duckdb_connector.py
src/nemo_retriever/tabular_data/dev_tools/benchmarks/bird/loader.py
src/nemo_retriever/tabular_data/dev_tools/benchmarks/bird/setup.py
src/nemo_retriever/tabular_data/dev_tools/benchmarks/spider2/loader.py
src/nemo_retriever/tabular_data/dev_tools/benchmarks/spider2/setup.py
src/nemo_retriever/tabular_data/ingestion/__init__.py
src/nemo_retriever/tabular_data/ingestion/extract_data.py
src/nemo_retriever/tabular_data/ingestion/indexes.py
src/nemo_retriever/tabular_data/ingestion/utils.py
src/nemo_retriever/tabular_data/ingestion/write_to_graph.py
src/nemo_retriever/tabular_data/ingestion/dal/__init__.py
src/nemo_retriever/tabular_data/ingestion/dal/db_dal.py
src/nemo_retriever/tabular_data/ingestion/dal/queries_dal.py
src/nemo_retriever/tabular_data/ingestion/dal/schemas_dal.py
src/nemo_retriever/tabular_data/ingestion/dal/utils_dal.py
src/nemo_retriever/tabular_data/ingestion/model/__init__.py
src/nemo_retriever/tabular_data/ingestion/model/neo4j_node.py
src/nemo_retriever/tabular_data/ingestion/model/query.py
src/nemo_retriever/tabular_data/ingestion/model/reserved_words.py
src/nemo_retriever/tabular_data/ingestion/model/schema.py
src/nemo_retriever/tabular_data/ingestion/parsers/__init__.py
src/nemo_retriever/tabular_data/ingestion/parsers/query_comparator.py
src/nemo_retriever/tabular_data/ingestion/parsers/schemas_parser.py
src/nemo_retriever/tabular_data/ingestion/parsers/sqlglot_extractor.py
src/nemo_retriever/tabular_data/ingestion/services/__init__.py
src/nemo_retriever/tabular_data/ingestion/services/queries.py
src/nemo_retriever/tabular_data/ingestion/services/schema.py
src/nemo_retriever/tabular_data/neo4j/__init__.py
src/nemo_retriever/tabular_data/neo4j/neo4j_connection.py
src/nemo_retriever/tabular_data/operators/__init__.py
src/nemo_retriever/tabular_data/operators/tabular_fetch_embeddings_operator.py
src/nemo_retriever/tabular_data/operators/tabular_schema_extract_operator.py
src/nemo_retriever/tabular_data/retrieval/__init__.py
src/nemo_retriever/tabular_data/retrieval/generate_sql.py
src/nemo_retriever/tabular_data/retrieval/llm_invoke.py
src/nemo_retriever/tabular_data/retrieval/data_access/__init__.py
src/nemo_retriever/tabular_data/retrieval/data_access/candidates.py
src/nemo_retriever/tabular_data/retrieval/data_access/custom_analyses.py
src/nemo_retriever/tabular_data/retrieval/data_access/foreign_keys.py
src/nemo_retriever/tabular_data/retrieval/data_access/graph_schemas.py
src/nemo_retriever/tabular_data/retrieval/data_access/relevant_tables.py
src/nemo_retriever/tabular_data/retrieval/data_access/response_formatting.py
src/nemo_retriever/tabular_data/retrieval/data_access/semantic_search.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/base.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/connector_routing.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/main.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/models.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/prompts.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/state.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/text_to_sql_graph.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/candidates_preparation.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/candidates_retrieval.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/entities_extraction.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/intent_validation.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/response.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/sql_execution.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/sql_from_semantic.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/sql_from_tables.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/sql_parse_validation.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/sql_reconstruction.py
src/nemo_retriever/tabular_data/retrieval/text_to_sql/agents/sql_unconstructable.py
src/nemo_retriever/tools/__init__.py
src/nemo_retriever/tools/benchmark/__init__.py
src/nemo_retriever/tools/benchmark/__main__.py
src/nemo_retriever/tools/benchmark/all_actor.py
src/nemo_retriever/tools/benchmark/audio_extract_actor.py
src/nemo_retriever/tools/benchmark/common.py
src/nemo_retriever/tools/benchmark/extract_actor.py
src/nemo_retriever/tools/benchmark/ocr_actor.py
src/nemo_retriever/tools/benchmark/page_elements_actor.py
src/nemo_retriever/tools/benchmark/split_actor.py
src/nemo_retriever/tools/evaluation/__init__.py
src/nemo_retriever/tools/evaluation/cli.py
src/nemo_retriever/tools/evaluation/config.py
src/nemo_retriever/tools/evaluation/generation.py
src/nemo_retriever/tools/evaluation/ground_truth.py
src/nemo_retriever/tools/evaluation/judging.py
src/nemo_retriever/tools/evaluation/live_retrieval.py
src/nemo_retriever/tools/evaluation/orchestrator.py
src/nemo_retriever/tools/evaluation/retrieval_loader.py
src/nemo_retriever/tools/evaluation/retrievers.py
src/nemo_retriever/tools/evaluation/runner.py
src/nemo_retriever/tools/evaluation/scoring.py
src/nemo_retriever/tools/recall/__init__.py
src/nemo_retriever/tools/recall/__main__.py
src/nemo_retriever/tools/recall/beir.py
src/nemo_retriever/tools/recall/beir_eval.py
src/nemo_retriever/tools/recall/core.py
src/nemo_retriever/tools/recall/recall_eval.py
src/nemo_retriever/tools/recall/vdb_recall.py
src/nemo_retriever/tools/skill_eval/__init__.py
src/nemo_retriever/tools/skill_eval/__main__.py
src/nemo_retriever/tools/skill_eval/cli.py
src/nemo_retriever/tools/skill_eval/dataset.py
src/nemo_retriever/tools/skill_eval/report.py
src/nemo_retriever/tools/skill_eval/runner.py
src/nemo_retriever/tools/skill_eval/score.py
src/nemo_retriever/tools/skill_eval/trace_summarizer.py
src/nemo_retriever/tools/skill_eval/configs/__init__.py
src/nemo_retriever/tools/skill_eval/configs/skill_eval.yaml
src/nemo_retriever/tools/skill_eval/prompts/__init__.py
src/nemo_retriever/tools/skill_eval/prompts/setup_nl.j2
src/nemo_retriever/tools/skill_eval/prompts/setup_slash.j2
src/nemo_retriever/tools/skill_eval/prompts/trial_user_nl.j2
src/nemo_retriever/tools/skill_eval/prompts/trial_user_slash.j2
tests/test_actor_operators.py
tests/test_agentic_operators.py
tests/test_asr_actor.py
tests/test_audio_benchmark.py
tests/test_audio_chunk_actor.py
tests/test_audio_pipeline_batch.py
tests/test_audio_stage.py
tests/test_audio_visual_fuser.py
tests/test_beir_evaluation.py
tests/test_caption.py
tests/test_caption_model_profiles.py
tests/test_chart_graphic_elements.py
tests/test_ci_workflows.py
tests/test_container_ffmpeg_install.py
tests/test_cpu_module_import_safety.py
tests/test_create_local_embedder.py
tests/test_dedup.py
tests/test_detection_summary.py
tests/test_doc_to_pdf_actor.py
tests/test_embed_params.py
tests/test_evaluation_config.py
tests/test_evaluation_orchestrator.py
tests/test_evaluation_retrievers.py
tests/test_graph_ingestion_error_diagnostics.py
tests/test_graph_pipeline_cli.py
tests/test_graph_pipeline_registry.py
tests/test_harness_config.py
tests/test_harness_helm_manager.py
tests/test_harness_helm_profiles.py
tests/test_harness_history.py
tests/test_harness_nightly.py
tests/test_harness_portal.py
tests/test_harness_reporting.py
tests/test_harness_run.py
tests/test_helm_caption_endpoint.py
tests/test_helm_nimcache_model_profile.py
tests/test_helm_nimservice_resources.py
tests/test_helm_optional_nims_disabled_by_default.py
tests/test_helm_vectordb_embed_required.py
tests/test_hf_cache.py
tests/test_hf_embedder_padding.py
tests/test_hf_model_registry.py
tests/test_html_convert.py
tests/test_image_load.py
tests/test_ingest_config.py
tests/test_ingest_empty_validation.py
tests/test_ingest_interface.py
tests/test_ingest_manifest.py
tests/test_ingest_plans.py
tests/test_ingest_results.py
tests/test_ingest_retrieve_multimodal_pdf_integration.py
tests/test_io_dataframe.py
tests/test_io_image_store.py
tests/test_io_markdown.py
tests/test_lancedb_ivf_partitions.py
tests/test_lancedb_retrieval_where.py
tests/test_lancedb_row_metadata.py
tests/test_lancedb_write_policy.py
tests/test_live_rag.py
tests/test_llm_params.py
tests/test_media_dependency_availability.py
tests/test_multimodal_embed.py
tests/test_nemotron_ocr_v2_nightly.py
tests/test_nemotron_rerank_v2.py
tests/test_nemotron_rerank_vl_v2.py
tests/test_nemotron_rerank_vl_v2_hf.py
tests/test_nv_ingest_vdb_operator.py
tests/test_ocr_version_selection.py
tests/test_operator_flags_and_cpu_actors.py
tests/test_parakeet_ctc_hf_compat.py
tests/test_parakeet_infer_mode.py
tests/test_params_models.py
tests/test_params_utils.py
tests/test_pdf_render_scale.py
tests/test_pdf_stage_compact_json.py
tests/test_pipeline_graph.py
tests/test_pipeline_helpers.py
tests/test_pipeline_image_caption_concurrency.py
tests/test_probe_event_recording.py
tests/test_query_comparator.py
tests/test_query_workflow_options.py
tests/test_readme_video_pipeline_example.py
tests/test_recall_core.py
tests/test_remote_auth.py
tests/test_resource_heuristics.py
tests/test_retriever_queries.py
tests/test_root_cli_workflow.py
tests/test_root_query_cli.py
tests/test_semantic_search_metadata_filter_format.py
tests/test_service_caption.py
tests/test_service_client_compat.py
tests/test_service_embed.py
tests/test_service_ingest_async.py
tests/test_service_ingest_router.py
tests/test_service_ingestor_compat.py
tests/test_service_job_callback_diagnostics.py
tests/test_service_job_tracker.py
tests/test_service_media_dependency_gate.py
tests/test_service_pipeline_spec.py
tests/test_service_pool_metrics.py
tests/test_service_save_to_disk.py
tests/test_service_sidecar.py
tests/test_service_sinks.py
tests/test_service_sse.py
tests/test_service_vectordb_app.py
tests/test_service_worker_callback.py
tests/test_sidecar_metadata.py
tests/test_slim_imports_no_triton.py
tests/test_split_config.py
tests/test_split_config_integration.py
tests/test_sqlglot_extractor.py
tests/test_src_documentation_snippets.py
tests/test_store_pipeline_stages.py
tests/test_table_structure.py
tests/test_table_structure_nim_empty_bbox.py
tests/test_tabular_pipeline.py
tests/test_tabular_table_type.py
tests/test_txt_split.py
tests/test_type_aliases.py
tests/test_video_frame_actor.py
tests/test_video_frame_ocr_actor.py
tests/test_video_pipeline_batch.py
tests/test_video_recall.py
tests/test_video_text_dedup.py
tests/test_vllm_embed.py
tests/test_webhook_operator.py