ZADD requires an equal number of values and scores

[AleksSpace]

Good afternoon. I'm trying to set up the scheduler to work with Redis:

jobstores = {
    'default': RedisJobStore(host='redis', port=6379)
}
executors = {
    'default': {'type': 'threadpool', 'max_workers': 20},
    'processpool': ProcessPoolExecutor(max_workers=10)
}
job_defaults = {
    'coalesce': True,
    'max_instances': 3
}

scheduler = BackgroundScheduler()

scheduler.configure(
    jobstores=jobstores,
    executors=executors,
    job_defaults=job_defaults
)

I add a task:

scheduler.add_job(self.sending_messages_on_schedule,
                                  'cron', 
                                  start_date=data['since'], 
                                  minute=minute, 
                                  hour=hour, 
                                  day=day, 
                                  month=month, 
                                  day_of_week=day_of_week, 
                                  end_date=data['until'], 
                                  args=[subject, sender, recipient_email, mail_body, 
                                        dashboard_urls, slice_urls, file_paths, slice_names, dashboard_names], 
                                  id=f"job_id_{str(obj.id)}", 
                                  replace_existing=True, 
                                  coalesce=False,
                                  max_instances=3, 
                                  misfire_grace_time=1, 
                                  next_run_time=data['since'], 
                                  )

But I am getting an error:

Traceback (most recent call last):
File "/opt/project/superset/views/base.py", line 88, in wraps
     return f(self, *args, **kwargs)
File "/opt/project/superset/views/mailing_lists.py", line 389, in create_mailing_list
     next_run_time=data['since'],
File "/usr/local/lib/python3.6/site-packages/apscheduler/schedulers/base.py", line 447, in add_job
     self._real_add_job(job, jobstore, replace_existing)
File "/usr/local/lib/python3.6/site-packages/apscheduler/schedulers/base.py", line 871, in _real_add_job
     store.add_job(job)
 File "/usr/local/lib/python3.6/site-packages/apscheduler/jobstores/redis.py", line 85, in add_job
     {job.id: datetime_to_utc_timestamp(job.next_run_time)})
File "/usr/local/lib/python3.6/site-packages/redis/client.py", line 2315, in zadd
     raise RedisError("ZADD requires an equal number of "
redis.exceptions.RedisError: ZADD requires an equal number of values and scores

python==3.6
redis:alpine from DockerHub

Please tell me why is this happening?

[agronholm]

I have no idea. I take it you're working with the latest version of redis-py? If not, could you try to upgrade to the latest release? If that doesn't work, could you check what arguments it's trying to call zadd() with?

[AleksSpace]

Thank you, everything works) I updated Redis to version 4.0.0

[agronholm]

Why not 4.3.6? That's the latest version still compatible with Python 3.6.

[AleksSpace]

why is it better than 4.0.0?

[agronholm]

Later releases tend to have fewer bugs.

[AleksSpace]

Please tell me which version of APScheduler is needed to work with redis version 2.10.6?

[agronholm]

I'm not sure, but it's probably a very old one. Why not just upgrade to the latest redis-py client?

[AleksSpace]

it's just that the project I'm working on is very old and needs redis==2.10.6. Upgrading to a newer one will cause a lot of problems

[agronholm]

According to the version history, v3.5.3 seems to be the last release to work with redis-py v2.x.

[AleksSpace]

Thank you very much)

[AleksSpace]

Please tell me, why does this message show me 2 times at startup?

[agronholm]

Maybe you're running two schedulers there?