| 
1 | 1 | from __future__ import annotations  | 
2 | 2 | 
 
  | 
3 |  | -from typing import TYPE_CHECKING, Any, Callable, TypeVar  | 
 | 3 | +from typing import Any, Callable, TypeVar  | 
4 | 4 | 
 
  | 
5 | 5 | import redis.asyncio.client  | 
6 | 6 | import redis.asyncio.cluster  | 
 | 
10 | 10 | 
 
  | 
11 | 11 | from opentelemetry.trace import Span  | 
12 | 12 | 
 
  | 
13 |  | -if TYPE_CHECKING:  | 
14 |  | -    RequestHook = Callable[  | 
15 |  | -        [Span, redis.connection.Connection, list[Any], dict[str, Any]], None  | 
16 |  | -    ]  | 
17 |  | -    ResponseHook = Callable[[Span, redis.connection.Connection, Any], None]  | 
 | 13 | +RequestHook = Callable[  | 
 | 14 | +    [Span, redis.connection.Connection, list[Any], dict[str, Any]], None  | 
 | 15 | +]  | 
 | 16 | +ResponseHook = Callable[[Span, redis.connection.Connection, Any], None]  | 
18 | 17 | 
 
  | 
19 |  | -    AsyncPipelineInstance = TypeVar(  | 
20 |  | -        "AsyncPipelineInstance",  | 
21 |  | -        redis.asyncio.client.Pipeline,  | 
22 |  | -        redis.asyncio.cluster.ClusterPipeline,  | 
23 |  | -    )  | 
24 |  | -    AsyncRedisInstance = TypeVar(  | 
25 |  | -        "AsyncRedisInstance", redis.asyncio.Redis, redis.asyncio.RedisCluster  | 
26 |  | -    )  | 
27 |  | -    PipelineInstance = TypeVar(  | 
28 |  | -        "PipelineInstance",  | 
29 |  | -        redis.client.Pipeline,  | 
30 |  | -        redis.cluster.ClusterPipeline,  | 
31 |  | -    )  | 
32 |  | -    RedisInstance = TypeVar(  | 
33 |  | -        "RedisInstance", redis.client.Redis, redis.cluster.RedisCluster  | 
34 |  | -    )  | 
35 |  | -    R = TypeVar("R")  | 
 | 18 | +AsyncPipelineInstance = TypeVar(  | 
 | 19 | +    "AsyncPipelineInstance",  | 
 | 20 | +    redis.asyncio.client.Pipeline,  | 
 | 21 | +    redis.asyncio.cluster.ClusterPipeline,  | 
 | 22 | +)  | 
 | 23 | +AsyncRedisInstance = TypeVar(  | 
 | 24 | +    "AsyncRedisInstance", redis.asyncio.Redis, redis.asyncio.RedisCluster  | 
 | 25 | +)  | 
 | 26 | +PipelineInstance = TypeVar(  | 
 | 27 | +    "PipelineInstance",  | 
 | 28 | +    redis.client.Pipeline,  | 
 | 29 | +    redis.cluster.ClusterPipeline,  | 
 | 30 | +)  | 
 | 31 | +RedisInstance = TypeVar(  | 
 | 32 | +    "RedisInstance", redis.client.Redis, redis.cluster.RedisCluster  | 
 | 33 | +)  | 
 | 34 | +R = TypeVar("R")  | 
0 commit comments