File: connections.py

package info (click to toggle)
python-rq 2.6-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 2,580 kB
  • sloc: python: 13,878; makefile: 22; sh: 19
file content (13 lines) | stat: -rw-r--r-- 455 bytes parent folder | download 
1
2
3
4
5
6
7
8
9
10
11
12
13
 
from redis import Connection as RedisConnection
from redis import Redis


class NoRedisConnectionException(Exception):
    pass


def parse_connection(connection: Redis) -> tuple[type[Redis], type[RedisConnection], dict]:
    connection_pool_kwargs = connection.connection_pool.connection_kwargs.copy()
    connection_pool_class = connection.connection_pool.connection_class

    return connection.__class__, connection_pool_class, connection_pool_kwargs