Index

A

AbstractTaskQueue (class in worq.core) acquire() (worq.tests.util.TimeoutLock method)

assert_raises() (in module worq.tests.util)

B

Broker (class in worq.core)

Broker_duplicate_task_id() (in module worq.tests.test_core)

D

defer_task() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) Deferred (class in worq.task) deserialize() (worq.core.Broker method) discard_pending() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method)

discard_pending_tasks() (worq.core.Broker method) discard_result() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) discard_tasks() (in module worq.tests.pool.test_process)

E

enqueue_task() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) eq_() (in module worq.tests.util) eventually() (in module worq.tests.util)

example() (in module worq.tests.test_examples) expose() (worq.core.Broker method)

F

factory() (worq.queue.memory.TaskQueue class method)

force_kill_on_exit() (in module worq.tests.pool.test_process)

G

get() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) get_arguments() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) get_broker() (in module worq)

get_queue() (in module worq) get_redis_url() (in module worq.tests) get_status() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method)

H

has_value() (worq.task.Deferred method)

heartbeat() (worq.core.Broker method)

I

invoke() (worq.core.Broker method)

J

join() (worq.pool.process.WorkerPool method) (worq.pool.thread.WorkerPool method)

L

log_all_worq() (worq.queue.redis.TaskQueue method)

N

next_task() (worq.core.Broker method)

noop() (in module worq.tests.pool.test_process)

P

pid_running() (in module worq.tests.pool.test_process) ping() (worq.queue.redis.TaskQueue method) pop_result() (worq.core.AbstractTaskQueue method) (worq.core.Broker method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method)

PopenProcess (class in worq.pool.process) printlog() (in module worq.tests.pool.test_process) process_config() (in module worq.tests.pool.test_process)

Q

Queue (class in worq.task)

queue() (worq.core.Broker method)

R

reader() (in module worq.tests.pool.test_process) release() (worq.tests.util.TimeoutLock method)

reserve_argument() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) run_in_subprocess() (in module worq.pool.process)

S

serialize() (worq.core.Broker method) set_argument() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) set_result() (worq.core.AbstractTaskQueue method) (worq.core.Broker method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) set_task_timeout() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method) setup() (in module worq.tests) size() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method)

start() (worq.pool.process.WorkerPool method) (worq.pool.thread.WorkerPool method) start_pool() (in module worq.tests.pool.test_process) start_pools() (in module worq.pool.process) status (worq.task.Deferred attribute) status() (worq.core.Broker method) stop() (worq.pool.process.WorkerPool method) (worq.pool.thread.WorkerPool method)

T

Task (class in worq.task) task() (worq.task.TaskSpace method) task_failed() (worq.core.Broker method) TaskFailure TaskQueue (class in worq.queue.memory) (class in worq.queue.redis) TaskSpace (class in worq.task) tempdir() (in module worq.tests.util) test_Broker_duplicate_task_id_function() (in module worq.tests.test_core) test_Broker_duplicate_task_id_string() (in module worq.tests.test_core) test_Broker_task_failed() (in module worq.tests.test_core) test_clear_Queue() (in module worq.tests.test_task) test_completed_Deferred_as_argument() (in module worq.tests.test_task) test_deferred_task_fail_on_error() (in module worq.tests.test_task) test_examples() (in module worq.tests.test_examples)

test_Queue_default_options() (in module worq.tests.test_task) test_Queue_len() (in module worq.tests.test_task) test_redis_should_be_installed() (in module worq.tests) test_worker_interrupted() (in module worq.tests.test_task) test_WorkerPool_crashed_worker() (in module worq.tests.pool.test_process) test_WorkerPool_heartrate() (in module worq.tests.pool.test_process) test_WorkerPool_max_worker_tasks() (in module worq.tests.pool.test_process) test_WorkerPool_sigterm() (in module worq.tests.pool.test_process) test_WorkerPool_start_twice() (in module worq.tests.pool.test_process) test_WorkerPool_worker_shutdown_on_parent_die() (in module worq.tests.pool.test_process) thread_worker() (in module worq.tests.util) TimeoutLock (class in worq.tests.util) touch() (in module worq.tests.pool.test_process)

U

undefer_task() (worq.core.AbstractTaskQueue method) (worq.queue.memory.TaskQueue method) (worq.queue.redis.TaskQueue method)

utf8() (in module worq.queue.redis)

V

value (worq.task.Deferred attribute)

verify_shutdown() (in module worq.tests.pool.test_process)

W

wait() (worq.task.Deferred method) with_options() (worq.task.Task method) with_urls() (in module worq.tests.util) worker_pool() (in module worq.tests.pool.test_process) WorkerPool (class in worq.pool.process) (class in worq.pool.thread) WorkerPool_crashed_worker_init() (in module worq.tests.pool.test_process) WorkerPool_heartrate_init() (in module worq.tests.pool.test_process) WorkerPool_max_worker_tasks_init() (in module worq.tests.pool.test_process) WorkerPool_sigterm_init() (in module worq.tests.pool.test_process) WorkerPool_worker_shutdown_on_parent_die_init() (in module worq.tests.pool.test_process) worq (module) worq.const (module)

worq.core (module) worq.pool.process (module) worq.pool.thread (module) worq.queue.memory (module) worq.queue.redis (module) worq.task (module) worq.tests (module) worq.tests.pool.test_process (module) worq.tests.test_core (module) worq.tests.test_examples (module) worq.tests.test_task (module) worq.tests.util (module)