Simple job queues for Python
Dependency(allow_failure=True)
. Thanks @mattchan-tencent, @caffeinatedMike and @selwin!job.requeue()
now supports at_front()
argument. Thanks @buroa!SimpleWorker
now works better on Windows. Thanks @caffeinatedMike!on_failure
and on_success
arguments to @job decorator. Thanks @nepta1998!result_ttl=0
. Thanks @selwin!ssl_cert_reqs
argument to be passed to Redis. Thanks @mgcdanny!job.cancel()
should also remove itself from registries. Thanks @joshcoden!daemon
mode. Thanks @mik3y!CanceledJobRegistry
to keep track of canceled jobs. Thanks @selwin!cancel_job(job_id, enqueue_dependents=True)
allows you to cancel a job while enqueueing its dependents. Thanks @joshcoden!job.get_meta()
to fetch fresh meta value directly from Redis. Thanks @aparcar!job.exc_info
. Thanks @selwin!queue.enqueue(foo, on_success=do_this, on_failure=do_that)
. Thanks @selwin!queue.enqueue_many()
to enqueue many jobs in one go. Thanks @joshcoden!Scheduler
now works with custom serializers. Thanks @alella!RoundRobinWorker
and RandomWorker
classes to control how jobs are dequeued from multiple queues. Thanks @bielcardona!--serializer
option to rq worker
CLI. Thanks @f0cker!STOPPED
job status so that you can differentiate between failed and manually stopped jobs. Thanks @dralley!clean_worker_registry()
now works in batches of 1,000 jobs to prevent modifying too many keys at once. Thanks @AxeOfMen and @TheSneak!job.worker_name
attribute that tells you which worker is executing a job. Thanks @selwin!send_stop_job_command()
that tells a worker to stop executing a job. Thanks @selwin!JSONSerializer
as an alternative to the default pickle
based serializer. Thanks @JackBoreczky!RQScheduler
running on Redis with ssl=True
. Thanks @BobReid!send_shutdown_command()
and send_kill_horse_command()
. Thanks @selwin!job.last_heartbeat
property that's periodically updated when job is running. Thanks @theambient!FailedJobRegistry
. Thanks @selwin!