From 6bb7cb716601a72309f956fe1167fd4aeb4b562f Mon Sep 17 00:00:00 2001 From: Eric Eastwood Date: Tue, 2 Aug 2022 11:43:28 -0500 Subject: Revert "Non-working try baggage to inherit force tracing/sampling" This reverts commit d15fa457c987f51908cdba440655a0d6d88573a9. --- synapse/logging/tracing.py | 60 ++++++---------------------------------------- 1 file changed, 7 insertions(+), 53 deletions(-) (limited to 'synapse/logging') diff --git a/synapse/logging/tracing.py b/synapse/logging/tracing.py index 4396c0e0ce..b9fb17c9a8 100644 --- a/synapse/logging/tracing.py +++ b/synapse/logging/tracing.py @@ -619,32 +619,6 @@ def start_span( if kind is None: kind = SpanKind.INTERNAL - if context is None: - context = get_context_from_span(get_active_span()) - - logger.info( - "is_context_forced_tracing(context)=%s context=%s", - is_context_forced_tracing(context), - context, - ) - - if is_context_forced_tracing(context): - parent_span_context = get_span_context_from_context(context) - if parent_span_context: - force_sample_span_context = opentelemetry.trace.span.SpanContext( - trace_id=parent_span_context.trace_id, - span_id=parent_span_context.span_id, - is_remote=False, - # Force sampled so this trace is exported - trace_flags=opentelemetry.trace.TraceFlags( - opentelemetry.trace.TraceFlags.SAMPLED - ), - ) - # Overwrite the context with the sampled flag on - context = trace.set_span_in_context( - opentelemetry.trace.NonRecordingSpan(force_sample_span_context) - ) - return tracer.start_span( name=name, context=context, @@ -803,38 +777,18 @@ def force_tracing(span: Optional["opentelemetry.trace.span.Span"] = None) -> Non # regardless of what IsRecording/Sampled on the SpanContext says span.set_attribute(SynapseTags.FORCE_TRACING, True) - ctx = get_context_from_span(span) - logger.info("set_baggage on ctx=%s", ctx) - # This doesn't work because `set_baggage` returns a new context - # that we can't apply back to the span so the baggage is lost - opentelemetry.baggage.set_baggage( - SynapseBaggage.FORCE_TRACING, "1", context=ctx - ) - - force_tracing_baggage = opentelemetry.baggage.get_baggage( - SynapseBaggage.FORCE_TRACING, context=ctx - ) - opentelemetry.baggage.set_baggage("foo", "bar", context=ctx) - foo_baggage = opentelemetry.baggage.get_baggage("foo", context=ctx) - # TODO: Why is this still None after we just set it? - logger.info( - "after set_baggage on force_tracing_baggage=%s foo_baggage=%s", - force_tracing_baggage, - foo_baggage, - ) + # ctx = get_context_from_span(span) + # opentelemetry.baggage.set_baggage( + # SynapseBaggage.FORCE_TRACING, "1", context=ctx + # ) def is_context_forced_tracing( - context: "opentelemetry.context.context.Context", + span_context: Optional["opentelemetry.shim.opentracing_shim.SpanContextShim"], ) -> bool: """Check if sampling has been force for the given span context.""" - force_tracing_baggage = opentelemetry.baggage.get_baggage( - SynapseBaggage.FORCE_TRACING, context=context - ) - logger.info( - "is_context_forced_tracing force_tracing_baggage=%s", force_tracing_baggage - ) - return force_tracing_baggage is not None + # TODO + return False # Injection and extraction -- cgit 1.5.1