check if raw is present before calling close

Signed-off-by: Alex Boten <[email protected]>

Author: codeboten

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

@@ -167,10 +167,12 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
             resp = self._export(serialized_data)
             # pylint: disable=no-else-return
             if resp.ok:
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 return LogExportResult.SUCCESS
             elif self._retryable(resp):
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting logs batch, retrying in %ss.",
                     resp.reason,
@@ -179,7 +181,8 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
                 sleep(delay)
                 continue
             else:
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 _logger.error(
                     "Failed to export logs batch code: %s, reason: %s",
                     resp.status_code,

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

@@ -206,10 +206,12 @@ def export(
             resp = self._export(serialized_data.SerializeToString())
             # pylint: disable=no-else-return
             if resp.ok:
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 return MetricExportResult.SUCCESS
             elif self._retryable(resp):
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting metric batch, retrying in %ss.",
                     resp.reason,
@@ -218,7 +220,8 @@ def export(
                 sleep(delay)
                 continue
             else:
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 _logger.error(
                     "Failed to export batch code: %s, reason: %s",
                     resp.status_code,

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/trace_exporter/__init__.py

@@ -159,10 +159,12 @@ def _export_serialized_spans(self, serialized_data):
             resp = self._export(serialized_data)
             # pylint: disable=no-else-return
             if resp.ok:
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 return SpanExportResult.SUCCESS
             elif self._retryable(resp):
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting span batch, retrying in %ss.",
                     resp.reason,
@@ -171,7 +173,8 @@ def _export_serialized_spans(self, serialized_data):
                 sleep(delay)
                 continue
             else:
-                resp.close()
+                if resp.raw != None:
+                    resp.close()
                 _logger.error(
                     "Failed to export batch code: %s, reason: %s",
                     resp.status_code,