Index

A

app() (in module eqsql.proxies) are_queues_empty() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

as_completed() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

C

cancel() (eqsql.task_queues.core.Future method) (eqsql.worker_pool.LocalPool method) (eqsql.worker_pool.ScheduledPool method) cancel_tasks() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

CANCELED (eqsql.task_queues.core.TaskStatus attribute) cfg_file_to_dict() (in module eqsql.worker_pool) cfg_tofile() (in module eqsql.worker_pool) clear_queues() (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) close() (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) COMPLETE (eqsql.task_queues.core.TaskStatus attribute)

D

done() (eqsql.task_queues.core.Future method)

dump_proxies() (in module eqsql.proxies)

E

eqsql.db_tools module eqsql.proxies module eqsql.task_queues.core module eqsql.task_queues.gc_queue module

eqsql.task_queues.local_queue module eqsql.task_queues.service_queue module eqsql.worker_pool module

F

FAILURE (eqsql.task_queues.core.ResultStatus attribute)

format_pool_exp_id() (in module eqsql.worker_pool) Future (class in eqsql.task_queues.core)

G

GCTaskQueue (class in eqsql.task_queues.gc_queue) get_priorities() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method) get_status() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

get_worker_pools() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

I

init() (in module eqsql.proxies) init_eqsql_db() (in module eqsql.db_tools)

init_task_queue() (in module eqsql.task_queues.gc_queue) (in module eqsql.task_queues.local_queue) (in module eqsql.task_queues.service_queue)

L

load_proxies() (in module eqsql.proxies)

LocalPool (class in eqsql.worker_pool) LocalTaskQueue (class in eqsql.task_queues.local_queue)

M

module eqsql.db_tools eqsql.proxies eqsql.task_queues.core eqsql.task_queues.gc_queue eqsql.task_queues.local_queue eqsql.task_queues.service_queue eqsql.worker_pool

P

pop_completed() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

pop_in_queue() (eqsql.task_queues.local_queue.LocalTaskQueue method) pop_out_queue() (eqsql.task_queues.local_queue.LocalTaskQueue method) priority (eqsql.task_queues.core.Future property) push_in_queue() (eqsql.task_queues.local_queue.LocalTaskQueue method) push_out_queue() (eqsql.task_queues.local_queue.LocalTaskQueue method)

Q

query_more_tasks() (eqsql.task_queues.local_queue.LocalTaskQueue method) query_result() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

query_task() (eqsql.task_queues.local_queue.LocalTaskQueue method) QUEUED (eqsql.task_queues.core.TaskStatus attribute)

R

random() (in module eqsql.task_queues.local_queue) report_task() (eqsql.task_queues.local_queue.LocalTaskQueue method) REQUEUED (eqsql.task_queues.core.TaskStatus attribute)

reset_db() (in module eqsql.db_tools) result() (eqsql.task_queues.core.Future method) ResultStatus (class in eqsql.task_queues.core) RUNNING (eqsql.task_queues.core.TaskStatus attribute)

S

ScheduledPool (class in eqsql.worker_pool) select_task_payload() (eqsql.task_queues.local_queue.LocalTaskQueue method) select_task_result() (eqsql.task_queues.local_queue.LocalTaskQueue method) ServiceTaskQueue (class in eqsql.task_queues.service_queue) start_db() (in module eqsql.db_tools) start_local_pool() (in module eqsql.worker_pool) start_scheduled_pool() (in module eqsql.worker_pool) status (eqsql.task_queues.core.Future property) status() (eqsql.worker_pool.LocalPool method) (eqsql.worker_pool.ScheduledPool method) stop_db() (in module eqsql.db_tools)

stop_worker_pool() (eqsql.task_queues.local_queue.LocalTaskQueue method) StopConditionException submit_task() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method) submit_tasks() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method) SUCCESS (eqsql.task_queues.core.ResultStatus attribute)

T

TaskQueue (class in eqsql.task_queues.core)

TaskStatus (class in eqsql.task_queues.core) TimeoutError

U

update_priorities() (eqsql.task_queues.core.TaskQueue method) (eqsql.task_queues.gc_queue.GCTaskQueue method) (eqsql.task_queues.local_queue.LocalTaskQueue method) (eqsql.task_queues.service_queue.ServiceTaskQueue method)

update_task() (eqsql.task_queues.local_queue.LocalTaskQueue method)

W

worker_pool (eqsql.task_queues.core.Future property)