BLMOVE throws syntax error

[Pleochism]

I'm pretty sure I'm not doing anything weird here.

payload = await redis.blmove("dispatch-queue", "processing-queue", "LEFT", "RIGHT", 1)

This throws a syntax error on v5.3.1, with Redis 7.0.15

  File "dispatcher/main.py", line 83, in run_redis
    payload = await redis.blmove("room-dispatcher.queue", "room-dispatcher.processing", "LEFT", "RIGHT", 1)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/daniel/.cache/pypoetry/virtualenvs/dispatcher-jV_AsfwX-py3.12/lib/python3.12/site-packages/redis/asyncio/client.py", line 677, in execute_command
    return await conn.retry.call_with_retry(
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/daniel/.cache/pypoetry/virtualenvs/dispatcher-jV_AsfwX-py3.12/lib/python3.12/site-packages/redis/asyncio/retry.py", line 50, in call_with_retry
    return await do()
           ^^^^^^^^^^
  File "/home/daniel/.cache/pypoetry/virtualenvs/dispatcher-jV_AsfwX-py3.12/lib/python3.12/site-packages/redis/asyncio/client.py", line 652, in _send_command_parse_response
    return await self.parse_response(conn, command_name, **options)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/daniel/.cache/pypoetry/virtualenvs/dispatcher-jV_AsfwX-py3.12/lib/python3.12/site-packages/redis/asyncio/client.py", line 698, in parse_response
    response = await connection.read_response()
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/daniel/.cache/pypoetry/virtualenvs/dispatcher-jV_AsfwX-py3.12/lib/python3.12/site-packages/redis/asyncio/connection.py", line 627, in read_response
    raise response from None

LMOVE works fine, it's just the blocking variant that does this.

[petyaslavova]

Hi @Pleochism, thank you for bringing this up!
Can you please share more information about how your async client is initialized - are you using protocol 2 or 3? Are you using hiredis? When does it happen - on empty list or on list that contains elements?
I tried to run it locally with latest versions of Redis and redis-py and I wasn't able to reproduce it, so if have some chance, would you please try if it will be reproducible with latest redis-py version?

[Pleochism]

Thanks for the questions. I am using Hiredis, so I tested agin without it on the latest version and everything worked. I then added Hiredis back and it still works, lol. The thing is, I definitely tested 7.0.1 originally; downgrading to 5.x was my attempt to fix the issue. So I guess something somewhere got mixed up in my packages and broke, who knows. Anyway, thanks :) No issue then.

[Pleochism]

Ah, no, sorry, I was mistaken. I forgot to actually add the blmove back to my code. So on the latest version it still happens, with or without Hiredis. It also happens on 6.4,0.

[petyaslavova]

Hi @Pleochism, I think I found the problem in your command...

payload = await redis.blmove("dispatch-queue", "processing-queue", "LEFT", "RIGHT", 1)

This is the definition of the command:

def blmove(
        self,
        first_list: str,
        second_list: str,
        timeout: int,
        src: str = "LEFT",
        dest: str = "RIGHT",
    )

The timeout should be before the src and dest arguments - in your case you have set it after them.
Can you please try to change the order of the args and test again?

[Pleochism]

Oh my word, I didn't even think to check that. Thank you, I'll verify on Monday but it's almost certainly that.