Browse Source

Fix opentelemetry access

tags/v0.0.0-test-pr-120
Philipp Oppermann 3 years ago
parent
commit
9ba990b816
Failed to extract signature
2 changed files with 2 additions and 2 deletions
  1. +1
    -1
      binaries/runtime/src/operator/python.rs
  2. +1
    -1
      binaries/runtime/src/operator/shared_lib.rs

+ 1
- 1
binaries/runtime/src/operator/python.rs View File

@@ -98,7 +98,7 @@ pub fn spawn(
use opentelemetry::trace::TraceContextExt;
use opentelemetry::{trace::Tracer, Context as OtelContext};

let cx = deserialize_context(&input.metadata.open_telemetry_context);
let cx = deserialize_context(&input.metadata.parameters.open_telemetry_context);
let span = tracer.start_with_context(format!("{}", input.id), &cx);

let child_cx = OtelContext::current_with_span(span);


+ 1
- 1
binaries/runtime/src/operator/shared_lib.rs View File

@@ -139,7 +139,7 @@ impl<'lib> SharedLibraryOperator<'lib> {

let span = tracer.start_with_context(
format!("{}", input.id),
&deserialize_context(&input.metadata.open_telemetry_context),
&deserialize_context(&input.metadata.parameters.open_telemetry_context),
);
let child_cx = OtelContext::current_with_span(span);
let string_cx = serialize_context(&child_cx);


Loading…
Cancel
Save