redis.exceptions.ReadOnlyError: You can't write against a read only replica.

[z0z0r4]

Issues

GitHub issues are for bugs. If you have questions, please ask them on the mailing list.

Checklist

• Does your title concisely summarize the problem?
• Did you include a minimal, reproducible example?
• What OS are you using?
• What version of Dramatiq are you using?
• What did you do?
• What did you expect would happen?
• What happened?

What OS are you using?

debian

What version of Dramatiq are you using?

1.16.0

What did you do?

I didn't enable dramatiq.middleware.prometheus, running the dramatiq...Just place there

What happened?

[2024-06-07 17:11:46,489] [PID 1763313] [MainThread] [dramatiq.MainProcess] [INFO] Dramatiq '1.16.0' is booting up.
[2024-06-07 17:11:46,486] [PID 1763314] [MainThread] [dramatiq.WorkerProcess(0)] [INFO] Worker process is ready for action.
[2024-06-07 17:11:46,456] [PID 1763315] [MainThread] [dramatiq.WorkerProcess(1)] [INFO] Worker process is ready for action.
[2024-06-07 17:11:46,489] [PID 1763359] [MainThread] [dramatiq.ForkProcess(0)] [INFO] Fork process 'dramatiq.middleware.prometheus:_run_exposition_server' is ready for action.
    for message in self.consumer:
  File "/opt/mcim/lib/python3.10/site-packages/dramatiq/brokers/redis.py", line 363, in __next__
    self.message_cache = messages = self.broker.do_fetch(
  File "/opt/mcim/lib/python3.10/site-packages/dramatiq/brokers/redis.py", line 281, in do_dispatch
    return dispatch(args=args, keys=keys)
  File "/opt/mcim/lib/python3.10/site-packages/redis/commands/core.py", line 5931, in __call__
    return client.evalsha(self.sha, len(keys), *args)
  File "/opt/mcim/lib/python3.10/site-packages/redis/commands/core.py", line 5307, in evalsha
    return self._evalsha("EVALSHA", sha, numkeys, *keys_and_args)
  File "/opt/mcim/lib/python3.10/site-packages/redis/commands/core.py", line 5291, in _evalsha
    return self.execute_command(command, sha, numkeys, *keys_and_args)
  File "/opt/mcim/lib/python3.10/site-packages/redis/client.py", line 536, in execute_command
    return conn.retry.call_with_retry(
  File "/opt/mcim/lib/python3.10/site-packages/redis/retry.py", line 46, in call_with_retry
    return do()
  File "/opt/mcim/lib/python3.10/site-packages/redis/client.py", line 537, in <lambda>
    lambda: self._send_command_parse_response(
  File "/opt/mcim/lib/python3.10/site-packages/redis/client.py", line 513, in _send_command_parse_response
    return self.parse_response(conn, command_name, **options)
  File "/opt/mcim/lib/python3.10/site-packages/redis/client.py", line 553, in parse_response
    response = connection.read_response()
  File "/opt/mcim/lib/python3.10/site-packages/redis/connection.py", line 524, in read_response
    raise response
redis.exceptions.ReadOnlyError: You can't write against a read only replica. script: 976fb89fbb3c404c8c7bed59060c56521eb9ba69, on @user_script:58.