Skip to content

Commit 12ea823

Browse files
committed
update retryable error codes initialization logic
1 parent 96757ec commit 12ea823

1 file changed

Lines changed: 8 additions & 7 deletions

File tree

  • exporter/opentelemetry-exporter-otlp-proto-grpc/src/opentelemetry/exporter/otlp/proto/grpc

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

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
2121
"""
2222

23+
import os
2324
import random
2425
import threading
2526
from abc import ABC, abstractmethod
@@ -359,20 +360,20 @@ def __init__(
359360
else compression
360361
) or Compression.NoCompression
361362

362-
self._retryable_error_codes = (
363-
frozenset(retryable_error_codes)
364-
if retryable_error_codes is not None
365-
else environ.get(
366-
_OTEL_PYTHON_EXPORTER_OTLP_GRPC_RETRYABLE_ERROR_CODES
367-
)
363+
self._retryable_error_codes = retryable_error_codes or os.environ.get(
364+
_OTEL_PYTHON_EXPORTER_OTLP_GRPC_RETRYABLE_ERROR_CODES
368365
)
369366
if isinstance(self._retryable_error_codes, str):
370367
self._retryable_error_codes = frozenset(
371368
StatusCode[code.strip().upper()]
372369
for code in self._retryable_error_codes.split(",")
373370
if code.strip()
374371
)
375-
if self._retryable_error_codes is None:
372+
elif self._retryable_error_codes is not None:
373+
self._retryable_error_codes = frozenset(
374+
self._retryable_error_codes
375+
)
376+
else:
376377
self._retryable_error_codes = _RETRYABLE_ERROR_CODES
377378

378379
self._channel = None

0 commit comments

Comments
 (0)