Index

A

ALL_PRIORITIES_STARVED (pulq.models.enums.NoWorkReason attribute) (pulq.NoWorkReason attribute)

assigned_worker_id (pulq.models.task.Task attribute) (pulq.Task attribute)

C

claim_next_pending() (pulq.InMemoryTaskRepository method) (pulq.storage.memory.InMemoryTaskRepository method) (pulq.TaskRepository method) (pulq.types.TaskRepository method) claimable_priorities (pulq.core.scheduler.DeficitScheduler property) (pulq.DeficitScheduler property) command (pulq.ManagementCommand attribute) (pulq.models.work.ManagementCommand attribute) CommandDispatcher (class in pulq) (class in pulq.core.dispatcher)

commands (pulq.core.pull_queue.PullQueue property) (pulq.PullQueue property) CommandType (class in pulq) (class in pulq.models.enums) COMPLETED (pulq.models.enums.TaskStatus attribute) (pulq.TaskStatus attribute) created_at (pulq.models.task.Task attribute) (pulq.Task attribute) credit_all() (pulq.core.scheduler.DeficitScheduler method) (pulq.DeficitScheduler method)

D

debit() (pulq.core.scheduler.DeficitScheduler method) (pulq.DeficitScheduler method) deficits (pulq.core.pull_queue.PullQueue property) (pulq.PullQueue property)

DeficitScheduler (class in pulq) (class in pulq.core.scheduler) DeficitSchedulerConfig (class in pulq) (class in pulq.models.scheduler_config)

E

enqueue() (pulq.CommandDispatcher method) (pulq.core.dispatcher.CommandDispatcher method)

F

FAILED (pulq.models.enums.TaskStatus attribute) (pulq.TaskStatus attribute)

G

get_next() (pulq.core.pull_queue.PullQueue method) (pulq.PullQueue method)

H

has_pending_for() (pulq.CommandDispatcher method) (pulq.core.dispatcher.CommandDispatcher method)

HeartbeatCallback (class in pulq) (class in pulq.types)

I

id (pulq.models.task.Task attribute) (pulq.Task attribute) InMemoryTaskRepository (class in pulq) (class in pulq.storage.memory)

is_epoch_complete (pulq.core.scheduler.DeficitScheduler property) (pulq.DeficitScheduler property) issued_at (pulq.ManagementCommand attribute) (pulq.models.work.ManagementCommand attribute)

L

LocalTransport (class in pulq) (class in pulq.transport.local)

M

ManagementCommand (class in pulq) (class in pulq.models.work) mark_complete() (pulq.core.pull_queue.PullQueue method) (pulq.InMemoryTaskRepository method) (pulq.PullQueue method) (pulq.storage.memory.InMemoryTaskRepository method) (pulq.TaskRepository method) (pulq.types.TaskRepository method) metadata (pulq.models.task.Task attribute) (pulq.Task attribute) model_config (pulq.DeficitSchedulerConfig attribute) (pulq.ManagementCommand attribute) (pulq.models.scheduler_config.DeficitSchedulerConfig attribute) (pulq.models.task.Task attribute) (pulq.models.work.ManagementCommand attribute) (pulq.models.work.NoPendingTask attribute) (pulq.models.work.NoWork attribute) (pulq.NoPendingTask attribute) (pulq.NoWork attribute) (pulq.Task attribute)

module pulq pulq.core.dispatcher pulq.core.pull_queue pulq.core.scheduler pulq.core.worker pulq.models.enums pulq.models.scheduler_config pulq.models.task pulq.models.unions pulq.models.work pulq.parsing pulq.storage.memory pulq.transport.local pulq.types

N

NoPendingTask (class in pulq) (class in pulq.models.work) NoWork (class in pulq) (class in pulq.models.work)

NoWorkReason (class in pulq) (class in pulq.models.enums)

P

parse_claim_result() (in module pulq) (in module pulq.parsing) parse_work_response() (in module pulq) (in module pulq.parsing) PAUSE (pulq.CommandType attribute) (pulq.models.enums.CommandType attribute) payload (pulq.models.task.Task attribute) (pulq.Task attribute) PENDING (pulq.models.enums.TaskStatus attribute) (pulq.TaskStatus attribute) priority (pulq.models.task.Task attribute) (pulq.models.work.NoPendingTask attribute) (pulq.NoPendingTask attribute) (pulq.Task attribute) priority_order (pulq.DeficitSchedulerConfig attribute) (pulq.models.scheduler_config.DeficitSchedulerConfig attribute) PullQueue (class in pulq) (class in pulq.core.pull_queue) pulq module pulq.core.dispatcher module pulq.core.pull_queue module

pulq.core.scheduler module pulq.core.worker module pulq.models.enums module pulq.models.scheduler_config module pulq.models.task module pulq.models.unions module pulq.models.work module pulq.parsing module pulq.storage.memory module pulq.transport.local module pulq.types module

Q

quantum (pulq.DeficitSchedulerConfig attribute) (pulq.models.scheduler_config.DeficitSchedulerConfig attribute)

Queue (in module pulq) QUEUE_EMPTY (pulq.models.enums.NoWorkReason attribute) (pulq.NoWorkReason attribute)

R

reason (pulq.models.work.NoWork attribute) (pulq.NoWork attribute) report_completion() (pulq.LocalTransport method) (pulq.Transport method) (pulq.transport.local.LocalTransport method) (pulq.types.Transport method) request_work() (pulq.LocalTransport method) (pulq.Transport method) (pulq.transport.local.LocalTransport method) (pulq.types.Transport method)

RESUME (pulq.CommandType attribute) (pulq.models.enums.CommandType attribute) run() (pulq.core.worker.Worker method) (pulq.Worker method) RUNNING (pulq.models.enums.TaskStatus attribute) (pulq.TaskStatus attribute)

S

schedule() (pulq.core.pull_queue.PullQueue method) (pulq.InMemoryTaskRepository method) (pulq.PullQueue method) (pulq.storage.memory.InMemoryTaskRepository method) (pulq.TaskRepository method) (pulq.types.TaskRepository method) send() (pulq.CommandDispatcher method) (pulq.core.dispatcher.CommandDispatcher method)

send_command() (pulq.core.pull_queue.PullQueue method) (pulq.PullQueue method) status (pulq.models.task.Task attribute) (pulq.Task attribute) STOP (pulq.CommandType attribute) (pulq.models.enums.CommandType attribute)

T

take_next_for() (pulq.CommandDispatcher method) (pulq.core.dispatcher.CommandDispatcher method) Task (class in pulq) (class in pulq.models.task) TaskHandler (class in pulq) (class in pulq.types) TaskRepository (class in pulq) (class in pulq.types) TaskStatus (class in pulq) (class in pulq.models.enums)

Transport (class in pulq) (class in pulq.types) type (pulq.ManagementCommand attribute) (pulq.models.task.Task attribute) (pulq.models.work.ManagementCommand attribute) (pulq.models.work.NoPendingTask attribute) (pulq.models.work.NoWork attribute) (pulq.NoPendingTask attribute) (pulq.NoWork attribute) (pulq.Task attribute)

W

weights (pulq.DeficitSchedulerConfig attribute) (pulq.models.scheduler_config.DeficitSchedulerConfig attribute) weights_have_no_unknown_priorities() (pulq.DeficitSchedulerConfig class method) (pulq.models.scheduler_config.DeficitSchedulerConfig class method) weights_include_all_priorities() (pulq.DeficitSchedulerConfig class method) (pulq.models.scheduler_config.DeficitSchedulerConfig class method)

Worker (class in pulq) (class in pulq.core.worker) worker_id (pulq.core.worker.Worker property) (pulq.ManagementCommand attribute) (pulq.models.work.ManagementCommand attribute) (pulq.Worker property)

Z

zero_out() (pulq.core.scheduler.DeficitScheduler method) (pulq.DeficitScheduler method)