Switch pyright: to type:

Author: DylanRussell

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

@@ -109,7 +109,7 @@ def _translate_data(
     ) -> ExportLogsServiceRequest:
         return encode_logs(data)
 
-    def export(  # pyright: ignore [reportIncompatibleMethodOverride]
+    def export(  # type: ignore [reportIncompatibleMethodOverride]
         self,
         batch: Sequence[LogData],
     ) -> Literal[LogExportResult.SUCCESS, LogExportResult.FAILURE]:

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

@@ -304,7 +304,7 @@ def __init__(
             self._channel = secure_channel(
                 self._endpoint, credentials, compression=compression
             )
-        self._client = self._stub(self._channel)  # pyright: ignore [reportCallIssue]
+        self._client = self._stub(self._channel)  # type: ignore [reportCallIssue]
 
         self._export_lock = threading.Lock()
         self._shutdown = False
@@ -324,7 +324,7 @@ def _export(
         # not allowed and should return a Failure result.
         if self._shutdown:
             logger.warning("Exporter already shutdown, ignoring batch")
-            return self._result.FAILURE  # pyright: ignore [reportReturnType]
+            return self._result.FAILURE  # type: ignore [reportReturnType]
 
         # FIXME remove this check if the export type for traces
         # gets updated to a class that represents the proto
@@ -342,7 +342,7 @@ def _export(
             max_value=self._MAX_RETRY_TIMEOUT
         ):
             if delay == self._MAX_RETRY_TIMEOUT or self._shutdown:
-                return self._result.FAILURE  # pyright: ignore [reportReturnType]
+                return self._result.FAILURE  # type: ignore [reportReturnType]
 
             with self._export_lock:
                 try:
@@ -352,10 +352,10 @@ def _export(
                         timeout=self._timeout,
                     )
 
-                    return self._result.SUCCESS  # pyright: ignore [reportReturnType]
+                    return self._result.SUCCESS  # type: ignore [reportReturnType]
 
                 except RpcError as error:
-                    code = error.code()  # pyright: ignore [reportAttributeAccessIssue]
+                    code = error.code()  # type: ignore [reportAttributeAccessIssue]
                     if code in [
                         StatusCode.CANCELLED,
                         StatusCode.DEADLINE_EXCEEDED,
@@ -365,7 +365,7 @@ def _export(
                         StatusCode.UNAVAILABLE,
                         StatusCode.DATA_LOSS,
                     ]:
-                        retry_info_bin = dict(error.trailing_metadata()).get(  # pyright: ignore [reportAttributeAccessIssue]
+                        retry_info_bin = dict(error.trailing_metadata()).get(  # type: ignore [reportAttributeAccessIssue]
                             "google.rpc.retryinfo-bin"
                         )
                         if retry_info_bin is not None:
@@ -398,11 +398,11 @@ def _export(
                         )
 
                     if code == StatusCode.OK:
-                        return self._result.SUCCESS  # pyright: ignore [reportReturnType]
+                        return self._result.SUCCESS  # type: ignore [reportReturnType]
 
-                    return self._result.FAILURE  # pyright: ignore [reportReturnType]
+                    return self._result.FAILURE  # type: ignore [reportReturnType]
 
-        return self._result.FAILURE  # pyright: ignore [reportReturnType]
+        return self._result.FAILURE  # type: ignore [reportReturnType]
 
     def shutdown(self, timeout_millis: float = 30_000, **kwargs) -> None:
         if self._shutdown:

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

@@ -153,7 +153,7 @@ def __init__(
 
         self._max_export_batch_size: int | None = max_export_batch_size
 
-    def _translate_data(  # pyright: ignore [reportIncompatibleMethodOverride]
+    def _translate_data(  # type: ignore [reportIncompatibleMethodOverride]
         self, data: MetricsData
     ) -> ExportMetricsServiceRequest:
         return encode_metrics(data)