Skip to content

Commit a1b2681

Browse files
author
EGOROV Vadim
committed
fix creating middleware
1 parent 211d2d0 commit a1b2681

1 file changed

Lines changed: 11 additions & 14 deletions

File tree

microbootstrap/bootstrappers/litestar.py

Lines changed: 11 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -156,22 +156,19 @@ def build_litestar_route_details_from_scope(
156156
class LitestarOpenTelemetryInstrumentationMiddleware(ASGIMiddleware):
157157
def __init__(self, config: OpenTelemetryConfig) -> None:
158158
self.config = config
159-
self.open_telemetry_middleware = None
160159

161160
def create_open_telemetry_middleware(self, app: ASGIApp) -> OpenTelemetryMiddleware:
162-
if not self.open_telemetry_middleware:
163-
self.open_telemetry_middleware = OpenTelemetryMiddleware(
164-
app=app,
165-
client_request_hook=self.config.client_request_hook_handler, # type: ignore[arg-type]
166-
client_response_hook=self.config.client_response_hook_handler, # type: ignore[arg-type]
167-
default_span_details=build_litestar_route_details_from_scope,
168-
excluded_urls=get_excluded_urls(self.config.exclude_urls_env_key),
169-
meter=self.config.meter,
170-
meter_provider=self.config.meter_provider,
171-
server_request_hook=self.config.server_request_hook_handler,
172-
tracer_provider=self.config.tracer_provider,
173-
)
174-
return self.open_telemetry_middleware
161+
return OpenTelemetryMiddleware(
162+
app=app,
163+
client_request_hook=self.config.client_request_hook_handler, # type: ignore[arg-type]
164+
client_response_hook=self.config.client_response_hook_handler, # type: ignore[arg-type]
165+
default_span_details=build_litestar_route_details_from_scope,
166+
excluded_urls=get_excluded_urls(self.config.exclude_urls_env_key),
167+
meter=self.config.meter,
168+
meter_provider=self.config.meter_provider,
169+
server_request_hook=self.config.server_request_hook_handler,
170+
tracer_provider=self.config.tracer_provider,
171+
)
175172

176173
async def handle(self, scope: Scope, receive: Receive, send: Send, next_app: ASGIApp) -> None:
177174
await self.create_open_telemetry_middleware(next_app)(scope, receive, send)

0 commit comments

Comments
 (0)