Index

Symbols

--all redis_tasks-empty command line option --burst redis_tasks-worker command line option --by-queue redis_tasks-info command line option --delete redis_tasks-empty command line option --description redis_tasks-worker command line option --interval redis_tasks-info command line option --pythonpath redis_tasks command line option --quiet redis_tasks-scheduler command line option redis_tasks-worker command line option

--verbose redis_tasks-scheduler command line option redis_tasks-worker command line option --version redis_tasks command line option -b redis_tasks-worker command line option -d redis_tasks-worker command line option -i redis_tasks-info command line option -q redis_tasks-scheduler command line option redis_tasks-worker command line option -v redis_tasks-scheduler command line option redis_tasks-worker command line option

A

acquire() (redis_tasks.scheduler.Mutex method) activate() (redis_tasks.worker_process.PostponeShutdown method) add() (redis_tasks.registries.ExpiringRegistry method) (redis_tasks.registries.QueueRegistry method) (redis_tasks.registries.WorkerRegistry method)

all() (redis_tasks.queue.Queue class method) (redis_tasks.worker.Worker class method) assert_main_thread() (redis_tasks.worker_process.PostponeShutdown static method) atomic_pipeline() (in module redis_tasks.utils) await_multi() (redis_tasks.queue.Queue class method)

C

cancel() (redis_tasks.task.Task method) configure() (redis_tasks.conf.Settings method) configure_from_dict() (redis_tasks.conf.Settings method) configure_logging() (in module redis_tasks.cli)

construct_redis_key() (in module redis_tasks.conf) count() (redis_tasks.queue.Queue method) (redis_tasks.registries.ExpiringRegistry method) crontab (in module redis_tasks.scheduler) CrontabSchedule (class in redis_tasks.scheduler)

D

deactivate() (redis_tasks.worker_process.PostponeShutdown method) DEAD_WORKER_TTL decode_dict() (in module redis_tasks.utils) decode_list() (in module redis_tasks.utils) DEFAULT_TASK_TIMEOUT delete() (redis_tasks.queue.Queue method)

delete_many() (redis_tasks.task.Task class method) dequeue() (redis_tasks.queue.Queue method) DeserializationError deserialize() (in module redis_tasks.utils) died() (redis_tasks.worker.Worker method) DstSmearingTz (class in redis_tasks.smear_dst)

E

empty() (redis_tasks.queue.Queue method) (redis_tasks.registries.ExpiringRegistry method) end (redis_tasks.smear_dst.Transition property) end_task() (redis_tasks.worker.Worker method) enqueue() (redis_tasks.scheduler.SchedulerEntry method) (redis_tasks.task.Task method) enqueue_call() (redis_tasks.queue.Queue method) enum() (in module redis_tasks.utils) environment variable RT_SETTINGS_MODULE, [1], [2]

execute() (redis_tasks.task.Task method) execute_task() (redis_tasks.worker_process.WorkerProcess method) exists() (redis_tasks.conf.RTRedis method) expire() (redis_tasks.registries.ExpiringRegistry method) expire_script (redis_tasks.scheduler.Mutex attribute) EXPIRING_REGISTRIES_TTL ExpiringRegistry (class in redis_tasks.registries) extend() (redis_tasks.scheduler.Mutex method)

F

fetch() (redis_tasks.task.Task class method) (redis_tasks.worker.Worker class method) fetch_current_task() (redis_tasks.worker.Worker method)

fetch_many() (redis_tasks.task.Task class method) from_utc() (redis_tasks.smear_dst.DstSmearingTz method) ftime() (redis_tasks.conf.RTRedis method)

G

generate_callstring() (in module redis_tasks.utils) generate_worker_description() (in module redis_tasks.worker_process) get_abort_outcome() (redis_tasks.task.Task method) get_current_task() (in module redis_tasks.task) get_dead_ids() (redis_tasks.registries.WorkerRegistry method) get_names() (redis_tasks.registries.QueueRegistry method) get_next() (redis_tasks.scheduler.CrontabSchedule method) (redis_tasks.scheduler.PeriodicSchedule method)

get_running_tasks() (redis_tasks.registries.WorkerRegistry method) get_task_ids() (redis_tasks.queue.Queue method) (redis_tasks.registries.ExpiringRegistry method) get_tasks() (redis_tasks.queue.Queue method) (redis_tasks.registries.ExpiringRegistry method) get_worker_ids() (redis_tasks.registries.WorkerRegistry method)

H

handle_died_workers() (redis_tasks.registries.WorkerRegistry method) handle_outcome() (redis_tasks.task.Task method) handle_stop_signal() (redis_tasks.worker_process.WorkerProcess method)

handle_worker_death() (redis_tasks.task.Task method) heartbeat() (redis_tasks.registries.WorkerRegistry method) (redis_tasks.worker.Worker method)

I

ignore_shutdown_signal() (redis_tasks.worker_process.WorkHorse method) import_attribute() (in module redis_tasks.utils) install_signal_handlers() (redis_tasks.worker_process.WorkerProcess method) interruptible() (redis_tasks.worker_process.WorkerProcess method)

InvalidOperation is_enqueued() (redis_tasks.scheduler.SchedulerEntry method) is_reentrant (redis_tasks.task.Task property) is_serializable() (in module redis_tasks.utils)

K

key (redis_tasks.task.Task property)

key_for() (redis_tasks.task.Task class method)

L

LazyObject (class in redis_tasks.utils)

M

Maintenance (class in redis_tasks.worker_process) maybe_shutdown() (redis_tasks.worker_process.WorkerProcess method) MIDDLEWARE module redis_tasks redis_tasks.cli redis_tasks.conf redis_tasks.defaults redis_tasks.exceptions redis_tasks.queue redis_tasks.registries redis_tasks.scheduler redis_tasks.smear_dst redis_tasks.task redis_tasks.utils redis_tasks.worker redis_tasks.worker_process

Mutex (class in redis_tasks.scheduler)

N

new_method_proxy() (in module redis_tasks.utils)

new_utcoffset (redis_tasks.smear_dst.Transition property)

O

old_utcoffset (redis_tasks.smear_dst.Transition property)

once_per_day() (in module redis_tasks.scheduler) one() (in module redis_tasks.utils)

P

peek() (redis_tasks.task.TaskStack method) PeriodicSchedule (class in redis_tasks.scheduler) pipeline() (redis_tasks.conf.RTRedis method) pop() (redis_tasks.task.TaskStack method) PostponeShutdown (class in redis_tasks.worker_process)

print_separator() (in module redis_tasks.cli) process() (redis_tasks.scheduler.SchedulerEntry method) process_task() (redis_tasks.worker_process.WorkerProcess method) push() (redis_tasks.queue.Queue method) (redis_tasks.task.TaskStack method)

Q

Queue (class in redis_tasks.queue) queue (redis_tasks.task.Task property) queue_iter() (redis_tasks.worker_process.WorkerProcess method) QueueRegistry (class in redis_tasks.registries)

QUEUES redis_tasks-empty command line option redis_tasks-info command line option redis_tasks-worker command line option

R

REDIS_PREFIX redis_task() (in module redis_tasks.task) redis_tasks module redis_tasks command line option --pythonpath --version redis_tasks-empty command line option --all --delete QUEUES redis_tasks-info command line option --by-queue --interval -i QUEUES redis_tasks-scheduler command line option --quiet --verbose -q -v redis_tasks-worker command line option --burst --description --quiet --verbose -b -d -q -v QUEUES redis_tasks.cli module redis_tasks.conf module redis_tasks.defaults module

redis_tasks.exceptions module redis_tasks.queue module redis_tasks.registries module redis_tasks.scheduler module redis_tasks.smear_dst module redis_tasks.task module redis_tasks.utils module redis_tasks.worker module redis_tasks.worker_process module REDIS_URL refresh() (redis_tasks.task.Task method) (redis_tasks.worker.Worker method) registry_maintenance() (in module redis_tasks.registries) remove() (redis_tasks.registries.QueueRegistry method) (redis_tasks.registries.WorkerRegistry method) remove_and_delete() (redis_tasks.queue.Queue method) request_stop() (redis_tasks.worker_process.WorkHorse method) requeue() (redis_tasks.task.Task method) RESPONSE_CALLBACKS (redis_tasks.conf.RTRedis attribute) RT_SETTINGS_MODULE, [1] RTPipeline (class in redis_tasks.conf) RTRedis (class in redis_tasks.conf) run() (redis_tasks.scheduler.Scheduler method) (redis_tasks.worker_process.Maintenance method) (redis_tasks.worker_process.TWorker method) (redis_tasks.worker_process.WorkerProcess method) (redis_tasks.worker_process.WorkHorse method) run_every (in module redis_tasks.scheduler) run_if_neccessary() (redis_tasks.worker_process.Maintenance method)

S

save() (redis_tasks.scheduler.SchedulerEntry method) save_meta() (redis_tasks.task.Task method) SCHEDULE Scheduler (class in redis_tasks.scheduler) scheduler_main() (in module redis_tasks.scheduler) SCHEDULER_MAX_CATCHUP SCHEDULER_QUEUE SchedulerEntry (class in redis_tasks.scheduler) send_signal() (redis_tasks.worker_process.WorkHorse method) serialize() (in module redis_tasks.utils) set_failed() (redis_tasks.task.Task method) set_finished() (redis_tasks.task.Task method)

set_running() (redis_tasks.task.Task method) Settings (class in redis_tasks.conf) settings (in module redis_tasks.conf) setup_signal_handler() (redis_tasks.scheduler.Scheduler method) (redis_tasks.worker_process.WorkHorse method) show_queues() (in module redis_tasks.cli) show_workers() (in module redis_tasks.cli) shutdown() (redis_tasks.worker.Worker method) ShutdownRequested start (redis_tasks.smear_dst.Transition property) start_task() (redis_tasks.worker.Worker method) startup() (redis_tasks.worker.Worker method)

T

Task (class in redis_tasks.task) TaskAborted TaskDoesNotExist TaskOutcome (class in redis_tasks.task) TaskProperties (class in redis_tasks.task) TaskStack (class in redis_tasks.task)

timeout (redis_tasks.task.Task property) TIMEZONE to_utc() (redis_tasks.smear_dst.DstSmearingTz method) Transition (class in redis_tasks.smear_dst) trigger_shutdown() (redis_tasks.worker_process.PostponeShutdown class method) TWorker (class in redis_tasks.worker_process)

U

utc_end (redis_tasks.smear_dst.Transition property) utc_start (redis_tasks.smear_dst.Transition property)

utcformat() (in module redis_tasks.utils) utcnow() (in module redis_tasks.utils) utcparse() (in module redis_tasks.utils)

W

Worker (class in redis_tasks.worker) WORKER_DESCRIPTION_FUNCTION WORKER_HEARTBEAT_FREQ WORKER_HEARTBEAT_TIMEOUT worker_main() (in module redis_tasks.worker_process)

WORKER_PRELOAD_FUNCTION WorkerDoesNotExist WorkerProcess (class in redis_tasks.worker_process) WorkerRegistry (class in redis_tasks.registries) WorkerShutdown WorkHorse (class in redis_tasks.worker_process)

Z

zadd() (redis_tasks.conf.RTRedis method)