Skip to content

Commit 7eb6134

Browse files
committed
Remove args
1 parent 41581d3 commit 7eb6134

File tree

3 files changed

+8
-16
lines changed
  • exporter
    • opentelemetry-exporter-otlp-proto-grpc/src/opentelemetry/exporter/otlp/proto/grpc/_metric_exporter
    • opentelemetry-exporter-prometheus/src/opentelemetry/exporter/prometheus
  • opentelemetry-sdk/src/opentelemetry/sdk/_metrics/_internal

3 files changed

+8
-16
lines changed

exporter/opentelemetry-exporter-otlp-proto-grpc/src/opentelemetry/exporter/otlp/proto/grpc/_metric_exporter/__init__.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -169,9 +169,9 @@ def _translate_data(
169169
)
170170

171171
def export(
172-
self, metrics: Sequence[Metric], *args, **kwargs
172+
self, metrics: Sequence[Metric], **kwargs
173173
) -> MetricExportResult:
174174
return self._export(metrics)
175175

176-
def shutdown(self, *args, **kwargs):
176+
def shutdown(self, **kwargs):
177177
pass

exporter/opentelemetry-exporter-prometheus/src/opentelemetry/exporter/prometheus/__init__.py

+2-4
Original file line numberDiff line numberDiff line change
@@ -110,14 +110,12 @@ def __init__(self, prefix: str = "") -> None:
110110
REGISTRY.register(self._collector)
111111
self._collector._callback = self.collect
112112

113-
def _receive_metrics(
114-
self, metrics: Iterable[Metric], *args, **kwargs
115-
) -> None:
113+
def _receive_metrics(self, metrics: Iterable[Metric], **kwargs) -> None:
116114
if metrics is None:
117115
return
118116
self._collector.add_metrics_data(metrics)
119117

120-
def shutdown(self, *args, **kwargs) -> bool:
118+
def shutdown(self, **kwargs) -> bool:
121119
REGISTRY.unregister(self._collector)
122120
return True
123121

opentelemetry-sdk/src/opentelemetry/sdk/_metrics/_internal/measurement_consumer.py

+4-10
Original file line numberDiff line numberDiff line change
@@ -32,14 +32,12 @@
3232

3333
class MeasurementConsumer(ABC):
3434
@abstractmethod
35-
def consume_measurement(
36-
self, measurement: Measurement, *args, **kwargs
37-
) -> None:
35+
def consume_measurement(self, measurement: Measurement, **kwargs) -> None:
3836
pass
3937

4038
@abstractmethod
4139
def register_asynchronous_instrument(
42-
self, instrument: "_Asynchronous", *args, **kwargs
40+
self, instrument: "_Asynchronous", **kwargs
4341
):
4442
pass
4543

@@ -48,7 +46,6 @@ def collect(
4846
self,
4947
metric_reader: MetricReader,
5048
instrument_type_temporality: Dict[type, AggregationTemporality],
51-
*args,
5249
**kwargs
5350
) -> Iterable[Metric]:
5451
pass
@@ -67,14 +64,12 @@ def __init__(self, sdk_config: SdkConfiguration) -> None:
6764
}
6865
self._async_instruments: List["_Asynchronous"] = []
6966

70-
def consume_measurement(
71-
self, measurement: Measurement, *args, **kwargs
72-
) -> None:
67+
def consume_measurement(self, measurement: Measurement, **kwargs) -> None:
7368
for reader_storage in self._reader_storages.values():
7469
reader_storage.consume_measurement(measurement)
7570

7671
def register_asynchronous_instrument(
77-
self, instrument: "_Asynchronous", *args, **kwargs
72+
self, instrument: "_Asynchronous", **kwargs
7873
) -> None:
7974
with self._lock:
8075
self._async_instruments.append(instrument)
@@ -83,7 +78,6 @@ def collect(
8378
self,
8479
metric_reader: MetricReader,
8580
instrument_type_temporality: Dict[type, AggregationTemporality],
86-
*args,
8781
**kwargs
8882
) -> Iterable[Metric]:
8983
with self._lock:

0 commit comments

Comments
 (0)