Skip to content
Merged
Show file tree
Hide file tree
Changes from 4 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
([#4458](https://github.com/open-telemetry/opentelemetry-python/pull/4458))
- pylint-ci updated python version to 3.13
([#4450](https://github.com/open-telemetry/opentelemetry-python/pull/4450))
- Fix intermittent `Connection aborted` error when using otlp/http exporters
([#4477](https://github.com/open-telemetry/opentelemetry-python/pull/4477))

## Version 1.30.0/0.51b0 (2025-02-03)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -167,8 +167,10 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
resp = self._export(serialized_data)
# pylint: disable=no-else-return
if resp.ok:
resp.close()
return LogExportResult.SUCCESS
elif self._retryable(resp):
resp.close()
_logger.warning(
"Transient error %s encountered while exporting logs batch, retrying in %ss.",
resp.reason,
Expand All @@ -177,6 +179,7 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
sleep(delay)
continue
else:
resp.close()
_logger.error(
"Failed to export logs batch code: %s, reason: %s",
resp.status_code,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -206,8 +206,10 @@ def export(
resp = self._export(serialized_data.SerializeToString())
# pylint: disable=no-else-return
if resp.ok:
resp.close()
return MetricExportResult.SUCCESS
elif self._retryable(resp):
resp.close()
_logger.warning(
"Transient error %s encountered while exporting metric batch, retrying in %ss.",
resp.reason,
Expand All @@ -216,6 +218,7 @@ def export(
sleep(delay)
continue
else:
resp.close()
_logger.error(
"Failed to export batch code: %s, reason: %s",
resp.status_code,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -159,8 +159,10 @@ def _export_serialized_spans(self, serialized_data):
resp = self._export(serialized_data)
# pylint: disable=no-else-return
if resp.ok:
resp.close()
return SpanExportResult.SUCCESS
elif self._retryable(resp):
resp.close()
_logger.warning(
"Transient error %s encountered while exporting span batch, retrying in %ss.",
resp.reason,
Expand All @@ -169,6 +171,7 @@ def _export_serialized_spans(self, serialized_data):
sleep(delay)
continue
else:
resp.close()
_logger.error(
"Failed to export batch code: %s, reason: %s",
resp.status_code,
Expand Down
Loading