Skip to content

Commit aebe1ca

Browse files
committed
Remove vestigial try block and fix runtime issue where None[] or None.get() was being called
1 parent e6be925 commit aebe1ca

1 file changed

Lines changed: 23 additions & 23 deletions

File tree

src/workflows/services/common_service.py

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -200,32 +200,32 @@ def start_transport(self):
200200

201201
if otel_config and "timeout" not in otel_config:
202202
self.log.warning("Missing optional OTEL configuration field `timeout`. Will default to 10 seconds. ")
203+
204+
# Configure OTELTracing
205+
resource = Resource.create(
206+
{
207+
SERVICE_NAME: self._service_name,
208+
}
209+
)
203210

204-
# Configure OTELTracing
205-
resource = Resource.create(
206-
{
207-
SERVICE_NAME: self._service_name,
208-
}
209-
)
210-
211-
self.log.debug("Configuring OTELTracing")
212-
provider = TracerProvider(resource=resource)
213-
trace.set_tracer_provider(provider)
211+
self.log.debug("Configuring OTELTracing")
212+
provider = TracerProvider(resource=resource)
213+
trace.set_tracer_provider(provider)
214214

215-
# Configure BatchProcessor and OTLPSpanExporter using config values
216-
otlp_exporter = OTLPSpanExporter(
217-
endpoint=otel_config["endpoint"],
218-
timeout=otel_config.get("timeout", 10),
219-
)
220-
span_processor = BatchSpanProcessor(otlp_exporter)
221-
provider.add_span_processor(span_processor)
215+
# Configure BatchProcessor and OTLPSpanExporter using config values
216+
otlp_exporter = OTLPSpanExporter(
217+
endpoint=otel_config["endpoint"],
218+
timeout=otel_config.get("timeout", 10),
219+
)
220+
span_processor = BatchSpanProcessor(otlp_exporter)
221+
provider.add_span_processor(span_processor)
222222

223-
# Add OTELTracingMiddleware to the transport layer
224-
tracer = trace.get_tracer(__name__)
225-
otel_middleware = OTELTracingMiddleware(
226-
tracer, service_name=self._service_name
227-
)
228-
self._transport.add_middleware(otel_middleware)
223+
# Add OTELTracingMiddleware to the transport layer
224+
tracer = trace.get_tracer(__name__)
225+
otel_middleware = OTELTracingMiddleware(
226+
tracer, service_name=self._service_name
227+
)
228+
self._transport.add_middleware(otel_middleware)
229229

230230
metrics = self._environment.get("metrics")
231231
if metrics:

0 commit comments

Comments
 (0)