g
d dl mZ d dlmZ d dlmZmZ d dlmZ d dl m
Z
m Z m Z m
Z
d dlmZ d dlmZmZmZ d dlmZmZ d d lZ G d
d e Z G d d
e Ze G d de Zy ) ) annotations) dataclass)AnySequence)context)AggregationTemporalityMetricExporterMetricExportResult MetricsData) Aggregation) ReadableSpanSpan
SpanProcessor) SpanExporterSpanExportResultNc 2 e Zd ZdZddZddZd d
dZd dZy) WrapperSpanExporterz:A base class for SpanExporters that wrap another exporter.c || _ y N)wrapped_exporter)selfexporters X/var/www/openai/venv/lib/python3.12/site-packages/logfire/_internal/exporters/wrapper.py__init__z WrapperSpanExporter.__init__ s
( c 8 | j j | S r r export)r spanss r r zWrapperSpanExporter.export s $$++E22r c 8 | j j | S r r force_flushr timeout_milliss r r" z WrapperSpanExporter.force_flush $$00 @@r c 8 | j j y r r shutdownr s r r( z WrapperSpanExporter.shutdown s &&(r N)r r returnNone)r zSequence[ReadableSpan]r* r i0u r$ intr* boolr* r+ )__name__
__module__ __qualname____doc__r r r" r( r r r r s D)3A)r r c V e Zd ZdZ d d fd
Zdd dZdd
dZd d dZ xZS )
WrapperMetricExporterz | j j ||fi |S r r )r metrics_datar$ kwargss r r z WrapperMetricExporter.export+ s" +t$$++L.SFSSr c 8 | j j | S r r! r# s r r" z!WrapperMetricExporter.force_flush. r% r c > | j j |fi | y r r' )r r$ r? s r r( z WrapperMetricExporter.shutdown1 s & &&~@@r )NN)r r r9 z)dict[type, AggregationTemporality] | Noner: z dict[type, Aggregation] | Noner* r+ )i' )r> r r$ floatr? r r* r
)r$ rB r* r/ r, )r$ rB r? r r* r+ ) r1 r2 r3 r4 r r r" r(
__classcell__)r< s @r r7 r7 sT F
LP@D ) ) I) > )
)TAA Ar r7 c @ e Zd ZU dZded< d d
dZd dZd dZd
ddZy)WrapperSpanProcessorz s d#r c t j 5 | j j d d d y # 1 sw Y y xY wr )logfiresuppress_instrumentationrF r( r) s r r( z WrapperSpanProcessor.shutdownA s*
-
-
/ NN # # % 0
/
/s 9Ac t j 5 | j j | cd d d S # 1 sw Y y xY wr )rN rO rF r" r# s r r" z WrapperSpanProcessor.force_flushE s,
-
-
/>>--n= 0
/
/s :Ar )rI r rJ zcontext.Context | Noner* r+ )rI r
r* r+ r0 r, r- ) r1 r2 r3 r4 __annotations__rH rL r( r" r5 r r rE rE 5 s F 6$&>r rE )
__future__r dataclassesr typingr r
opentelemetryr opentelemetry.sdk.metrics.exportr r r
r opentelemetry.sdk.metrics.viewr opentelemetry.sdk.tracer
r r opentelemetry.sdk.trace.exportr r rN r r7 rE r5 r r rZ s[ " ! ! t t 6 E E I
),
) AN A, >= > >r