`faust.utils.tracing`¶

OpenTracing utilities.

faust.utils.tracing.current_span() → Optional[Span][source]¶

Get the current span for this context (if any).

faust.utils.tracing.noop_span() → Span[source]¶

Return a span that does nothing when traced.

faust.utils.tracing.set_current_span(span: Span) → None[source]¶

Set the current span for the current context.

faust.utils.tracing.finish_span(span: Optional[Span], *, error: Optional[BaseException] = None) → None[source]¶

Finish span, and optionally set error tag.

faust.utils.tracing.operation_name_from_fun(fun: Any) → str[source]¶

Generate opentracing name from function.

faust.utils.tracing.traced_from_parent_span(parent_span: Optional[Span] = None, callback: Optional[Callable] = None, **extra_context: Any) → Callable[source]¶

Decorate function to be traced from parent span.

faust.utils.tracing.call_with_trace(span: Span, fun: Callable, callback: Optional[Tuple[Callable, Tuple[Any, ...]]], *args: Any, **kwargs: Any) → Any[source]¶

Call function and trace it from parent span.

Faust