@@ -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