WorQ
Examples
worq Package
worq
Package
task
Module
core
Module
const
Module
Subpackages
WorQ
Docs
»
Edit on GitHub
Index
A
|
B
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
L
|
N
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
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)
Read the Docs
v: latest
Versions
latest
Downloads
PDF
HTML
Epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.