Simple job queues for Python
worker_pool.get_worker_process()
to make WorkerPool
easier to extend. Thanks @selwin!job.latest_result(timeout=60)
. Thanks @ajnisbet!stopped_callback
is not respected when job is enqueued via enqueue_many()
. Thanks @eswolinsky3241!worker-pool
no longer ignores --quiet
. Thanks @Mindiell!worker-pool
now starts with scheduler. Thanks @chromium7!Callback(on_stopped='my_callback)
. Thanks @eswolinsky3241!Callback
now accepts dotted path to function as input. Thanks @rishabh-ranjan!queue.enqueue_many()
now supports job dependencies. Thanks @eswolinsky3241!rq worker
CLI script now configures logging based on DICT_CONFIG
key present in config file. Thanks @juur!Worker
now uses lmove()
to implement reliable queue pattern. Thanks @selwin!Scheduler
should only release locks that it successfully acquires. Thanks @xzander!as_text()
function in v1.14. Thanks @tchapi!job.meta()
is loaded using the wrong serializer. Thanks @gabriels1234!WorkerPool
(beta) that manages multiple workers in a single CLI. Thanks @selwin!Callback
class that allows more flexibility in declaring job callbacks. Thanks @ronlut!--dequeue-strategy
option to RQ's CLI. Thanks @ccrvlh!--max-idle-time
option to RQ's worker CLI. Thanks @ronlut!--maintenance-interval
option to RQ's worker CLI. Thanks @ronlut!rq info
CLI command. Thanks @iggeehu!queue.enqueue_jobs()
now properly account for job dependencies. Thanks @sim6!TimerDeathPenalty
now properly handles negative/infinite timeout. Thanks @marqueurs404!work_horse_killed_handler
argument to Worker
. Thanks @ronlut!result_ttl
is -1
. Thanks @sim6!dequeue_timeout
ignores worker_ttl
. Thanks @ronlut!job.return_value()
instead of job.result
when processing callbacks. Thanks @selwin!Worker
code more easily extendable. Thanks @lowercase00!at_front
argument when jobs are scheduled. Thanks @gabriels1234!job.worker_name
after job is finished. Thanks @eswolinsky3241!queue.enqueue_many()
now supports on_success
and on on_failure
arguments. Thanks @y4n9squared!enqueue_at_front
to Dependency()
objects to put dependent jobs at the front when they are enqueued. Thanks @jtfidje!SETNAME
command. Thanks @yilmaz-burak!