search

liuliqiang / redisbeat

celery redis scheduler, dynamic add/modify/delete task from celery.
MIT License
172 stars 44 forks source link

Hi, I encountered the following error while using this framework. Could you please advise on how to resolve it? My Redis is in cluster mode. #43

Open tcxdgit opened 5 months ago

tcxdgit commented 5 months ago

File "/data/tasks.py", line 177, in scheduler = RedisScheduler(app=app) File "/usr/local/lib/python3.9/site-packages/redisbeat/scheduler.py", line 48, in init Scheduler.init(self, *args, *kwargs) File "/usr/local/lib/python3.9/site-packages/celery/beat.py", line 257, in init self.setup_schedule() File "/usr/local/lib/python3.9/site-packages/redisbeat/scheduler.py", line 68, in setup_schedule self.merge_inplace(self.app.conf.CELERYBEAT_SCHEDULE) File "/usr/local/lib/python3.9/site-packages/redisbeat/scheduler.py", line 75, in merge_inplace old_entries = self.rdb.zrangebyscore(self.key, 0, MAXINT, withscores=True) File "/usr/local/lib/python3.9/site-packages/redis/client.py", line 2861, in zrangebyscore return self.execute_command(pieces, options) File "/usr/local/lib/python3.9/site-packages/redis/client.py", line 898, in execute_command conn = self.connection or pool.get_connection(command_name, options) File "/usr/local/lib/python3.9/site-packages/redis/connection.py", line 1183, in get_connection connection.connect() File "/usr/local/lib/python3.9/site-packages/redis/connection.py", line 558, in connect self.on_connect() File "/usr/local/lib/python3.9/site-packages/redis/connection.py", line 655, in on_connect if nativestr(self.read_response()) != 'OK': File "/usr/local/lib/python3.9/site-packages/redis/connection.py", line 747, in read_response raise response redis.exceptions.ResponseError: SELECT is not allowed in cluster mode

liuliqiang commented 4 months ago

Hi @tcxdgit , what kind of redis are you using? And which type of redis cluster?