RedisJobStore(jobs_key='dispatched_trips_jobs',
run_times_key='dispatched_trips_running',
host='localhost',
db=2,
port=6379)
scheduler.add_jobstore(redis_storage, 'redis')
scheduler.add_job(my_func, 'cron', hour=10, minute=50, start_date='2022-06-01 09:00:00', jobstore='redis')
scheduler.start()
При добавлении таски вот такая ошибка:
pipe.hset(self.jobs_key, job.id, pickle.dumps(job.getstate(),
TypeError: cannot pickle 'weakref' object
Что упускаю?
Обрамляй код
Обсуждают сегодня