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#

nv_ingest.framework.orchestration.ray.stages.telemetry.otel_tracer.create_span_with_timestamps( tracer, parent_span, message, logger, ) → int[source]#

nv_ingest.framework.orchestration.ray.stages.telemetry.otel_tracer.extract_annotated_task_results(message)[source]#

nv_ingest.framework.orchestration.ray.stages.telemetry.otel_tracer.extract_timestamps_from_message(message)[source]#

nv_ingest.framework.orchestration.ray.stages.telemetry.otel_tracer.uuid_to_trace_id(uuid_str: str) → int[source]#: Convert a UUID-like string to an integer OpenTelemetry trace ID.

Module contents#