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#