Index

_

__init__() (shepherd.docker.DockerContainer method) (shepherd.docker.DockerImage method) (shepherd.errors.docker.DockerError method) (shepherd.runner.BaseRunner method) (shepherd.sheep.BareSheep method) (shepherd.sheep.BaseSheep method) (shepherd.sheep.DockerSheep method) (shepherd.shepherd.Shepherd method) (shepherd.storage.MinioStorage method) _build_run_command() (shepherd.docker.DockerContainer method) _CONTAINER_POINT (shepherd.sheep.DockerSheep attribute) _dequeue_and_feed_jobs() (shepherd.shepherd.Shepherd method) _download_object() (shepherd.storage.MinioStorage method) _ensure_auth_headers() (shepherd.storage.MinioStorage method) _ensure_user_agent_header() (shepherd.storage.MinioStorage static method) _get_object() (shepherd.storage.MinioStorage method) _get_sheep() (shepherd.shepherd.Shepherd method) _health_check() (shepherd.shepherd.Shepherd method)

_list_bucket() (shepherd.storage.MinioStorage method) _listen() (shepherd.shepherd.Shepherd method) _load_config() (shepherd.runner.BaseRunner method) _load_dataset() (shepherd.runner.BaseRunner method) _load_model() (shepherd.runner.BaseRunner method) (shepherd.sheep.BareSheep method) (shepherd.sheep.BaseSheep method) (shepherd.sheep.DockerSheep method) _login() (shepherd.docker.DockerImage method) _object_exists() (shepherd.storage.MinioStorage method) _process_job() (shepherd.runner.BaseRunner method) (shepherd.runner.JSONRunner method) _put_object() (shepherd.storage.MinioStorage method) _report_job_failed() (shepherd.shepherd.Shepherd method) _shepherd_health_check() (shepherd.shepherd.Shepherd method) _slaughter_all() (shepherd.shepherd.Shepherd method) _slaughter_sheep() (shepherd.shepherd.Shepherd method) _start_sheep() (shepherd.shepherd.Shepherd method) _upload_object() (shepherd.storage.MinioStorage method)

A

ApiClientError

ApiServerError

B

BareSheep (class in shepherd.sheep) BareSheep.Config (class in shepherd.sheep)

BaseRunner (class in shepherd.runner) BaseSheep (class in shepherd.sheep) BaseSheep.Config (class in shepherd.sheep)

C

close() (shepherd.shepherd.Shepherd method) (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method)

create_clean_dir() (in module shepherd.utils)

D

DockerContainer (class in shepherd.docker) DockerError (class in shepherd.errors.docker) DockerImage (class in shepherd.docker)

DockerSheep (class in shepherd.sheep) DockerSheep.Config (class in shepherd.sheep) DoneMessage (class in shepherd.comm)

E

enqueue_job() (shepherd.shepherd.Shepherd method) ErrorMessage (class in shepherd.comm)

exception_traceback (shepherd.comm.ErrorMessage attribute) exception_type (shepherd.comm.ErrorMessage attribute)

F

full_name (shepherd.docker.DockerImage property)

G

get_file() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method) get_job_status() (shepherd.shepherd.Shepherd method) (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method)

get_status() (shepherd.shepherd.Shepherd method)

I

identity (shepherd.comm.Message attribute) init_job() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method) InputMessage (class in shepherd.comm)

io_data_root (shepherd.comm.InputMessage attribute) is_accessible() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method) is_job_done() (shepherd.shepherd.Shepherd method)

J

job_dir_exists() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method)

job_id (shepherd.comm.Message attribute) JSONRunner (class in shepherd.runner)

K

kill() (shepherd.docker.DockerContainer method)

M

main() (in module shepherd.runner.runner_entry_point) Message (class in shepherd.comm) message (shepherd.comm.ErrorMessage attribute) MessageError Messenger (class in shepherd.comm) minio_object_exists() (in module shepherd.utils) MinioStorage (class in shepherd.storage) module shepherd shepherd.comm shepherd.docker shepherd.errors shepherd.errors.api shepherd.errors.comm shepherd.errors.docker shepherd.errors.sheep shepherd.runner shepherd.runner.runner_entry_point shepherd.sheep shepherd.shepherd shepherd.storage shepherd.utils

N

n_available_gpus() (in module shepherd.runner)

NameConflictError

P

process_all() (shepherd.runner.BaseRunner method) pull() (shepherd.docker.DockerImage method) pull_job_data() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method)

push_job_data() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method) put_file() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method)

R

recv() (shepherd.comm.Messenger static method) run() (in module shepherd.runner) running (shepherd.docker.DockerContainer property) (shepherd.sheep.BareSheep property) (shepherd.sheep.BaseSheep property) (shepherd.sheep.DockerSheep property)

S

send() (shepherd.comm.Messenger static method) set_job_status() (shepherd.storage.MinioStorage method) (shepherd.storage.Storage method) SheepConfigurationError (class in shepherd.errors.sheep) SheepError (class in shepherd.errors.sheep) shepherd module Shepherd (class in shepherd.shepherd) shepherd.comm module shepherd.docker module shepherd.errors module shepherd.errors.api module shepherd.errors.comm module shepherd.errors.docker module shepherd.errors.sheep module

shepherd.runner module shepherd.runner.runner_entry_point module shepherd.sheep module shepherd.shepherd module shepherd.storage module shepherd.utils module slaughter() (shepherd.sheep.BareSheep method) (shepherd.sheep.DockerSheep method) start() (shepherd.docker.DockerContainer method) (shepherd.sheep.BareSheep method) (shepherd.sheep.BaseSheep method) (shepherd.sheep.DockerSheep method) (shepherd.shepherd.Shepherd method) Storage (class in shepherd.storage) StorageError StorageInaccessibleError

T

to_json_serializable() (in module shepherd.runner)

U

UnexpectedMessageTypeError

UnknownJobError UnknownSheepError