@@ -101,6 +101,7 @@ def response_hook(span, instance, response):
101101
102102from opentelemetry import trace
103103from opentelemetry .instrumentation .instrumentor import BaseInstrumentor
104+ from opentelemetry .instrumentation .utils import unwrap
104105from opentelemetry .instrumentation .valkey .package import _instruments
105106from opentelemetry .instrumentation .valkey .util import (
106107 _extract_conn_attributes ,
@@ -109,7 +110,6 @@ def response_hook(span, instance, response):
109110 _value_or_none ,
110111)
111112from opentelemetry .instrumentation .valkey .version import __version__
112- from opentelemetry .instrumentation .utils import unwrap
113113from opentelemetry .semconv .trace import SpanAttributes
114114from opentelemetry .trace import Span , StatusCode , Tracer
115115
@@ -133,7 +133,9 @@ def response_hook(span, instance, response):
133133 valkey .asyncio .cluster .ClusterPipeline ,
134134 )
135135 AsyncValkeyInstance = TypeVar (
136- "AsyncValkeyInstance" , valkey .asyncio .Valkey , valkey .asyncio .ValkeyCluster
136+ "AsyncValkeyInstance" ,
137+ valkey .asyncio .Valkey ,
138+ valkey .asyncio .ValkeyCluster ,
137139 )
138140 PipelineInstance = TypeVar (
139141 "PipelineInstance" ,
0 commit comments