@@ -112,6 +112,7 @@ def on_start(
112
112
span: The :class:`opentelemetry.trace.Span` that just started.
113
113
parent_context: The parent context of the span that just started.
114
114
"""
115
+ ...
115
116
116
117
def on_end (self , span : "ReadableSpan" ) -> None :
117
118
"""Called when a :class:`opentelemetry.trace.Span` is ended.
@@ -122,9 +123,11 @@ def on_end(self, span: "ReadableSpan") -> None:
122
123
Args:
123
124
span: The :class:`opentelemetry.trace.Span` that just ended.
124
125
"""
126
+ ...
125
127
126
128
def shutdown (self ) -> None :
127
129
"""Called when a :class:`opentelemetry.sdk.trace.TracerProvider` is shutdown."""
130
+ ...
128
131
129
132
def force_flush (self , timeout_millis : int = 30000 ) -> bool :
130
133
"""Export all ended spans to the configured Exporter that have not yet
@@ -137,6 +140,7 @@ def force_flush(self, timeout_millis: int = 30000) -> bool:
137
140
Returns:
138
141
False if the timeout is exceeded, True otherwise.
139
142
"""
143
+ ...
140
144
141
145
142
146
# Temporary fix until https://github.com/PyCQA/pylint/issues/4098 is resolved
@@ -273,7 +277,7 @@ def force_flush(self, timeout_millis: int = 30000) -> bool:
273
277
timeout, False otherwise.
274
278
"""
275
279
futures = []
276
- for sp in self ._span_processors : # type: SpanProcessor
280
+ for sp in self ._span_processors :
277
281
future = self ._executor .submit (sp .force_flush , timeout_millis )
278
282
futures .append (future )
279
283
0 commit comments