Index

_

__init__() (debusine.tasks.Task method) (debusine.worker.Worker method)

A

abort() (debusine.tasks.Task method) ABORTED (debusine.db.models.WorkRequest.Statuses attribute) aborted() (debusine.db.models.WorkRequestManager method) (debusine.tasks.Task property)

analyze_worker() (debusine.tasks.Task method) analyze_worker_all_tasks() (debusine.tasks.Task class method) assign_worker() (debusine.db.models.WorkRequest method) assigned_work_requests (debusine.db.models.Worker attribute)

B

backend (debusine.db.models.FileStore attribute)

BackendChoices (debusine.db.models.FileStore attribute)

C

calculate_hash() (debusine.db.models.File class method) can_run_on() (debusine.tasks.Task method) class_from_name() (debusine.tasks.Task static method) close() (debusine.worker.Worker method) comment (debusine.db.models.Token attribute) COMPLETED (debusine.db.models.WorkRequest.Statuses attribute) completed() (debusine.db.models.WorkRequestManager method) completed_at (debusine.db.models.WorkRequest attribute)

configuration (debusine.db.models.FileStore attribute) configure() (debusine.tasks.Task method) connect() (debusine.worker.Worker method) connected() (debusine.db.models.Worker method) (debusine.db.models.WorkerManager method) connected_at (debusine.db.models.Worker attribute) create_with_fqdn() (debusine.db.models.WorkerManager class method) created_at (debusine.db.models.Token attribute) (debusine.db.models.WorkRequest attribute)

D

data (debusine.db.models.FileInStore attribute) (debusine.tasks.Task attribute) debusine.db.models module debusine.tasks module

debusine.worker module DEFAULT_LOG_LEVEL (debusine.worker.Worker attribute) disable() (debusine.db.models.Token method) duration() (debusine.db.models.WorkRequest property) dynamic_metadata (debusine.db.models.Worker attribute) dynamic_metadata_updated_at (debusine.db.models.Worker attribute)

E

enable() (debusine.db.models.Token method) enabled (debusine.db.models.Token attribute)

ERROR (debusine.db.models.WorkRequest.Results attribute) execute() (debusine.tasks.Task method)

F

FAILURE (debusine.db.models.WorkRequest.Results attribute) File (class in debusine.db.models) file (debusine.db.models.FileInStore attribute) File.DoesNotExist File.MultipleObjectsReturned file_id (debusine.db.models.FileInStore attribute) FileInStore (class in debusine.db.models) FileInStore.DoesNotExist FileInStore.MultipleObjectsReturned

fileinstore_set (debusine.db.models.File attribute) (debusine.db.models.FileStore attribute) files (debusine.db.models.FileStore attribute) FileStore (class in debusine.db.models) FileStore.DoesNotExist FileStore.MultipleObjectsReturned filestore_set (debusine.db.models.File attribute) FileStoreBackendChoices (class in debusine.db.models) from_local_path() (debusine.db.models.File class method)

G

get_backend_display() (debusine.db.models.FileStore method) get_next_by_created_at() (debusine.db.models.Token method) (debusine.db.models.WorkRequest method) get_next_by_registered_at() (debusine.db.models.Worker method) get_previous_by_created_at() (debusine.db.models.Token method) (debusine.db.models.WorkRequest method)

get_previous_by_registered_at() (debusine.db.models.Worker method) get_result_display() (debusine.db.models.WorkRequest method) get_status_display() (debusine.db.models.WorkRequest method) get_token_or_none() (debusine.db.models.TokenManager method) get_tokens() (debusine.db.models.TokenManager method) get_worker_by_token_key_or_none() (debusine.db.models.WorkerManager method) get_worker_or_none() (debusine.db.models.WorkerManager method)

H

hash_digest() (debusine.db.models.File property)

I

id (debusine.db.models.File attribute) (debusine.db.models.FileInStore attribute) (debusine.db.models.FileStore attribute) (debusine.db.models.Token attribute) (debusine.db.models.Worker attribute) (debusine.db.models.WorkRequest attribute)

is_valid_task_name() (debusine.tasks.Task static method)

K

key (debusine.db.models.Token attribute)

L

LOCAL (debusine.db.models.FileStoreBackendChoices attribute)

log_forced_exit() (debusine.worker.Worker static method) logger (debusine.tasks.Task attribute)

M

main() (debusine.worker.Worker method) mark_aborted() (debusine.db.models.WorkRequest method) mark_completed() (debusine.db.models.WorkRequest method) mark_connected() (debusine.db.models.Worker method) mark_disconnected() (debusine.db.models.Worker method)

mark_running() (debusine.db.models.WorkRequest method) metadata() (debusine.db.models.Worker method) module debusine.db.models debusine.tasks debusine.worker

N

name (debusine.db.models.FileStore attribute) (debusine.db.models.Worker attribute) (debusine.tasks.Task attribute)

NONE (debusine.db.models.WorkRequest.Results attribute)

O

objects (debusine.db.models.File attribute) (debusine.db.models.FileInStore attribute) (debusine.db.models.FileStore attribute) (debusine.db.models.Token attribute) (debusine.db.models.Worker attribute) (debusine.db.models.WorkRequest attribute)

owner (debusine.db.models.Token attribute)

P

PENDING (debusine.db.models.WorkRequest.Statuses attribute)

pending() (debusine.db.models.WorkRequestManager method) prefix_with_task_name() (debusine.tasks.Task method)

R

registered_at (debusine.db.models.Worker attribute) result (debusine.db.models.WorkRequest attribute)

RUNNING (debusine.db.models.WorkRequest.Statuses attribute) running() (debusine.db.models.WorkRequestManager method) running_or_pending_exists() (debusine.db.models.WorkRequestManager method)

S

save() (debusine.db.models.Token method) set_dynamic_metadata() (debusine.db.models.Worker method) sha256 (debusine.db.models.File attribute) size (debusine.db.models.File attribute) started_at (debusine.db.models.WorkRequest attribute)

static_metadata (debusine.db.models.Worker attribute) status (debusine.db.models.WorkRequest attribute) store (debusine.db.models.FileInStore attribute) store_id (debusine.db.models.FileInStore attribute) SUCCESS (debusine.db.models.WorkRequest.Results attribute)

T

Task (class in debusine.tasks) task_data (debusine.db.models.WorkRequest attribute) TASK_DATA_SCHEMA (debusine.tasks.Task attribute) task_name (debusine.db.models.WorkRequest attribute) task_names() (debusine.tasks.Task static method) TASK_VERSION (debusine.tasks.Task attribute)

TaskConfigError Token (class in debusine.db.models) token (debusine.db.models.Worker attribute) Token.DoesNotExist Token.MultipleObjectsReturned token_id (debusine.db.models.Worker attribute) TokenManager (class in debusine.db.models)

W

waiting_for_work_request() (debusine.db.models.WorkerManager method) Worker (class in debusine.db.models) (class in debusine.worker) worker (debusine.db.models.Token attribute) (debusine.db.models.WorkRequest attribute) Worker.DoesNotExist Worker.MultipleObjectsReturned

worker_id (debusine.db.models.WorkRequest attribute) WorkerManager (class in debusine.db.models) WorkRequest (class in debusine.db.models) WorkRequest.DoesNotExist WorkRequest.MultipleObjectsReturned WorkRequest.Results (class in debusine.db.models) WorkRequest.Statuses (class in debusine.db.models) WorkRequestManager (class in debusine.db.models)