(client)
| 126 | |
| 127 | |
| 128 | def get_protocol_version(client): |
| 129 | if isinstance(client, redis.Redis) or isinstance(client, redis.asyncio.Redis): |
| 130 | return client.connection_pool.connection_kwargs.get("protocol") |
| 131 | elif isinstance(client, redis.cluster.AbstractRedisCluster): |
| 132 | return client.nodes_manager.connection_kwargs.get("protocol") |
| 133 | |
| 134 | |
| 135 | def get_legacy_responses(client): |
no test coverage detected