File tree 2 files changed +6
-10
lines changed
2 files changed +6
-10
lines changed Original file line number Diff line number Diff line change 7
7
@lru_cache (maxsize = None )
8
8
async def check_for_command (conn , cmd ):
9
9
cmd_info = await conn .execute_command ("command" , "info" , cmd )
10
- return None not in cmd_info
10
+ return all ( cmd_info )
11
11
12
12
13
13
@lru_cache (maxsize = None )
14
14
async def has_redis_json (conn = None ):
15
- if not conn :
16
- conn = get_redis_connection ()
17
- command_exists = await check_for_command (conn , "json.set" )
15
+ command_exists = await check_for_command (conn or get_redis_connection (), "json.set" )
18
16
return command_exists
19
17
20
18
Original file line number Diff line number Diff line change 9
9
def get_redis_connection (** kwargs ) -> aioredis .Redis :
10
10
# If someone passed in a 'url' parameter, or specified a REDIS_OM_URL
11
11
# environment variable, we'll create the Redis client from the URL.
12
- url = kwargs .pop ("url" , URL )
13
- if url :
14
- return aioredis .Redis .from_url (url , ** kwargs )
15
-
12
+ if not kwargs .get ("url" , None ) and URL :
13
+ kwargs ["url" ] = URL
16
14
# Decode from UTF-8 by default
17
- if "decode_responses" not in kwargs :
15
+ if not kwargs . get ( "decode_responses" , None ) :
18
16
kwargs ["decode_responses" ] = True
19
- return aioredis .Redis (** kwargs )
17
+ return aioredis .from_url (** kwargs )
You can’t perform that action at this time.
0 commit comments