Index

_

__base__ (desipipe.environment.RegisteredEnvironment attribute) (desipipe.file_manager.RegisteredFileEntry attribute) (desipipe.io.RegisteredFile attribute) (desipipe.provider.RegisteredProvider attribute) (desipipe.scheduler.RegisteredScheduler attribute) (desipipe.utils.DictMetaClass attribute)

__class__ (desipipe.config.Config attribute) (desipipe.file_manager.FileManager attribute) (desipipe.task_manager.Queue attribute) (desipipe.task_manager.Task attribute) (desipipe.task_manager.TaskManager attribute)

A

action_from_args() (in module desipipe.task_manager) add() (desipipe.task_manager.Queue method)

app (desipipe.task_manager.Task attribute) append() (desipipe.file_manager.FileManager method)

B

BaseMetaClass (class in desipipe.utils)

bash_env() (in module desipipe.environment)

C

change_environ() (in module desipipe.environment) check_state_key() (desipipe.file_manager.YamlLoader method) chgdir() (desipipe.file_manager.FileManager method) clear() (desipipe.config.Config method) (desipipe.task_manager.Queue method) clear_memo() (desipipe.task_manager.TaskManagerPickler method) (desipipe.task_manager.TaskPickler method)

clone() (desipipe.file_manager.FileManager method) (desipipe.task_manager.Task method) (desipipe.task_manager.TaskManager method) common_options() (in module desipipe.file_manager) Config (class in desipipe.config) config_fn (desipipe.config.Config property) copytree() (in module desipipe.utils) counts() (desipipe.task_manager.Queue method)

D

databases() (desipipe.file_manager.FileManager class method) decode_slurm_time() (in module desipipe.provider) decorator() (in module desipipe.task_manager) delete() (desipipe.task_manager.Queue method) DeserializationError desipipe.config module desipipe.environment module desipipe.file_manager module desipipe.io module desipipe.provider module

desipipe.scheduler module desipipe.task_manager module desipipe.utils module dict_to_yaml() (in module desipipe.utils) DictMetaClass (class in desipipe.utils) dtime (desipipe.task_manager.Task attribute) dump() (desipipe.task_manager.TaskManagerPickler method) (desipipe.task_manager.TaskPickler method) dumps() (desipipe.task_manager.TaskManagerPickler class method) (desipipe.task_manager.TaskPickler class method)

E

environ (desipipe.task_manager.TaskManager attribute) Environment() (in module desipipe.environment) err (desipipe.task_manager.Task attribute)

errno (desipipe.task_manager.Task attribute) exception_handler() (in module desipipe.utils) exists() (desipipe.file_manager.FileManager method)

F

FileManager (class in desipipe.file_manager) filepaths (desipipe.file_manager.FileManager property)

find_class() (desipipe.task_manager.TaskManagerUnpickler method) (desipipe.task_manager.TaskUnpickler method)

G

get() (desipipe.config.Config method) (desipipe.file_manager.FileManager method) get_environ() (in module desipipe.environment) get_file_entry() (in module desipipe.file_manager)

get_filetype() (in module desipipe.io) get_provider() (in module desipipe.provider) get_queue() (in module desipipe.task_manager) get_scheduler() (in module desipipe.scheduler)

I

id (desipipe.task_manager.Task attribute) in_options() (in module desipipe.file_manager) index() (desipipe.file_manager.FileManager method) is_path() (in module desipipe.utils)

is_sequence() (in module desipipe.utils) items() (desipipe.config.Config method) iter() (desipipe.file_manager.FileManager method) iter_options() (desipipe.file_manager.FileManager method)

J

jobid (desipipe.task_manager.Task attribute)

JointMetaClass (class in desipipe.file_manager)

K

keys() (desipipe.config.Config method)

kill() (in module desipipe.task_manager) kwargs (desipipe.task_manager.Task attribute)

L

load() (desipipe.task_manager.TaskManagerUnpickler method) (desipipe.task_manager.TaskUnpickler method)

loads() (desipipe.task_manager.TaskManagerUnpickler class method) (desipipe.task_manager.TaskUnpickler class method) LoggingContext (class in desipipe.utils)

M

managers() (desipipe.task_manager.Queue method) mkdir() (in module desipipe.utils) module desipipe.config desipipe.environment desipipe.file_manager desipipe.io desipipe.provider desipipe.scheduler desipipe.task_manager desipipe.utils

mro() (desipipe.environment.RegisteredEnvironment method) (desipipe.file_manager.JointMetaClass method) (desipipe.file_manager.RegisteredFileEntry method) (desipipe.io.RegisteredFile method) (desipipe.provider.RegisteredProvider method) (desipipe.scheduler.RegisteredScheduler method) (desipipe.utils.BaseMetaClass method) (desipipe.utils.DictMetaClass method) MyStream (class in desipipe.task_manager)

O

options (desipipe.file_manager.FileManager property)

out (desipipe.task_manager.Task attribute)

P

pause() (desipipe.task_manager.Queue method) paused (desipipe.task_manager.Queue property) pop() (desipipe.config.Config method) (desipipe.task_manager.Queue method)

popitem() (desipipe.config.Config method) processes() (desipipe.task_manager.Queue method) provider (desipipe.task_manager.TaskManager attribute) Provider() (in module desipipe.provider)

Q

Queue (class in desipipe.task_manager) queue (desipipe.task_manager.TaskManager attribute)

queue_dir (desipipe.config.Config property) QueueState (class in desipipe.task_manager)

R

reduce_app() (in module desipipe.task_manager) register() (desipipe.environment.RegisteredEnvironment method) (desipipe.file_manager.JointMetaClass method) (desipipe.utils.DictMetaClass method) RegisteredEnvironment (class in desipipe.environment) RegisteredFile (class in desipipe.io) RegisteredFileEntry (class in desipipe.file_manager)

RegisteredProvider (class in desipipe.provider) RegisteredScheduler (class in desipipe.scheduler) require_ids (desipipe.task_manager.Task attribute) result (desipipe.task_manager.Task attribute) resume() (desipipe.task_manager.Queue method) retry() (in module desipipe.task_manager) run() (desipipe.task_manager.Task method)

S

save() (desipipe.file_manager.FileManager method) scheduler (desipipe.task_manager.TaskManager attribute) Scheduler() (in module desipipe.scheduler) select() (desipipe.file_manager.FileManager method) select_modules() (in module desipipe.task_manager) SerializationError set_logger() (desipipe.environment.RegisteredEnvironment method) (desipipe.file_manager.JointMetaClass method) (desipipe.file_manager.RegisteredFileEntry method) (desipipe.io.RegisteredFile method) (desipipe.provider.RegisteredProvider method) (desipipe.scheduler.RegisteredScheduler method) (desipipe.utils.BaseMetaClass method) (desipipe.utils.DictMetaClass method)

set_task_state() (desipipe.task_manager.Queue method) setdefault() (desipipe.config.Config method) setup_logging() (in module desipipe.utils) spawn() (desipipe.task_manager.TaskManager method) (in module desipipe.task_manager) state (desipipe.task_manager.Queue property) (desipipe.task_manager.Task attribute) summary() (desipipe.task_manager.Queue method) symlink() (desipipe.file_manager.FileManager method)

T

t0 (desipipe.task_manager.Task attribute) Task (class in desipipe.task_manager) TaskManager (class in desipipe.task_manager) TaskManagerPickler (class in desipipe.task_manager) TaskManagerUnpickler (class in desipipe.task_manager)

TaskPickler (class in desipipe.task_manager) tasks() (desipipe.task_manager.Queue method) TaskState (class in desipipe.task_manager) TaskUnpickler (class in desipipe.task_manager) tid (desipipe.task_manager.TaskManager attribute) time_lru_cache() (in module desipipe.provider)

U

unique_id() (in module desipipe.task_manager) update() (desipipe.config.Config method) (desipipe.file_manager.FileManager method) (desipipe.task_manager.Task method) (desipipe.task_manager.TaskManager method)

V

values() (desipipe.config.Config method)

VarType (class in desipipe.task_manager) versions (desipipe.task_manager.Task attribute)

W

with_traceback() (desipipe.task_manager.DeserializationError method) (desipipe.task_manager.SerializationError method)

work() (in module desipipe.task_manager)

Y

yaml_parser() (in module desipipe.file_manager)

YamlLoader (class in desipipe.file_manager)