Index

A

add_work() (s3workers.manager.Manager method)

all_jobs_submitted() (s3workers.work_queue.WorkQueue method)

F

finish() (s3workers.progress.S3KeyProgress method) (s3workers.progress.SimpleProgress method)

I

is_done() (s3workers.work_queue.WorkQueue method)

J

Job (class in s3workers.jobs)

M

Manager (class in s3workers.manager)

R

reduce() (s3workers.reducer.Reducer method) Reducer (class in s3workers.reducer) report() (s3workers.progress.S3KeyProgress method) (s3workers.progress.SimpleProgress method)

run() (s3workers.jobs.Job method) (s3workers.worker.Worker method)

S

S3KeyProgress (class in s3workers.progress) S3ListJob (class in s3workers.jobs) s3workers (module) s3workers.cli (module) s3workers.jobs (module) s3workers.manager (module) s3workers.progress (module)

s3workers.reducer (module) s3workers.work_queue (module) s3workers.worker (module) SimpleProgress (class in s3workers.progress) start_workers() (s3workers.manager.Manager method) stop() (s3workers.jobs.Job method) (s3workers.worker.Worker method) stop_workers() (s3workers.manager.Manager method)

W

wait_for_workers() (s3workers.manager.Manager method) Worker (class in s3workers.worker)

WorkQueue (class in s3workers.work_queue) write() (s3workers.progress.S3KeyProgress method) (s3workers.progress.SimpleProgress method)