json commands with async redis: Redis.executed_command was never awaited

[nikkicoon]

Are the JSONCommands only synchronous?
I'm trying to use json get and set from asynchronous functions in python 3.13.9.

I'm getting RuntimeWarning: coroutine 'Redis.execute_command' was never awaited for a call of

...
self.client.json().set(name=key, path=path, obj=data, decode_keys=decode_keys, nx=kwargs.get("nx", False))
...

where self.client is redis.asyncio.Redis or an asyncio Sentinel, depending on configuration.
direct commands like self.client.scan_iter and others work.
the above line can not awaited as far as I'm aware and what commands.json.commands.py indicates.

Do I have to implement my own json get and json set? I'm glad for any pointers.

[petyaslavova]

Hi @nikkicoon, when you call the provided example above, do you use await?

res = await self.client.json().set(name=key, path=path, obj=data, decode_keys=decode_keys, nx=kwargs.get("nx", False))

The support for the async comes with the call to self.execute_command("JSON.SET", *pieces) inside the json module method implementations, which in async context awaits for the command execution, parses the response and returns the parsed response

redis-py/redis/asyncio/client.py

Line 715 in 20bdf4d

async def execute_command(self, *args, **options):

[nikkicoon]

Hi, I think I changing one line and waiting for those functions probably solved my problem. Thanks for the hint (and even more so for the explanation), I think I overlooked this even though I had it await before.