queue Package

memory Module

In-memory message queue and result store.

class worq.queue.memory.TaskQueue(*args, **kw)[source]

Bases: worq.core.AbstractTaskQueue

Simple in-memory task queue implementation

defer_task(result, message, args)[source]
discard_pending()[source]
discard_result(task_id, task_expired_token)[source]
enqueue_task(result, message)[source]
classmethod factory(url, name='default', *args, **kw)[source]
get(timeout=None)[source]
get_arguments(task_id)[source]
get_status(task_id)[source]
pop_result(task_id, timeout)[source]
reserve_argument(argument_id, deferred_id)[source]
set_argument(task_id, argument_id, message)[source]
set_result(task_id, message, timeout)[source]
set_task_timeout(task_id, timeout)[source]
size()[source]
undefer_task(task_id)[source]

redis Module

Redis message queue and result store.

class worq.queue.redis.TaskQueue(url, name='default', initial_result_timeout=60, redis_factory=<class 'redis.client.StrictRedis'>)[source]

Bases: worq.core.AbstractTaskQueue

Redis task queue

defer_task(result, message, args)[source]
discard_pending()[source]
discard_result(task_id, task_expired_token)[source]
enqueue_task(result, message)[source]
get(timeout=0)[source]
get_arguments(task_id)[source]
get_status(task_id)[source]
log_all_worq(show_expiring=False)[source]

debugging helper

ping()[source]
pop_result(task_id, timeout)[source]
reserve_argument(argument_id, deferred_id)[source]
set_argument(task_id, argument_id, message)[source]
set_result(task_id, message, timeout)[source]
set_task_timeout(task_id, timeout)[source]
size()[source]
undefer_task(task_id)[source]
worq.queue.redis.utf8(value)[source]