Index

_

__init__() (fedflow.context.WorkDirContext method) (fedflow.core.task.Task method) (fedflow.core.taskgroup.TaskGroup method) (fedflow.units.ByteUnits method) (fedflow.utils.trainer.SupervisedTrainer method)

A

add_group() (fedflow.FedFlow class method) add_task() (fedflow.core.taskgroup.TaskGroup method)

assign_cuda() (fedflow.core.scheduler.GroupScheduler class method) AVAILABLE (fedflow.core.task.TaskStatus attribute)

B

ByteUnits (class in fedflow.units)

C

cmd (fedflow.core.message.Message property) convert() (fedflow.units.ByteUnits class method) (fedflow.units.Units class method)

cpu_free() (fedflow.core.scheduler.GroupScheduler class method)

D

data (fedflow.core.message.Message property)

device (fedflow.core.taskgroup.TaskGroup property)

E

EXCEPTION (fedflow.core.task.TaskStatus attribute) exists_module() (fedflow.utils.ModuleUtils class method)

exit() (fedflow.core.task.Task method) EXITED (fedflow.core.task.TaskStatus attribute)

F

fedflow module FedFlow (class in fedflow) fedflow.config module fedflow.context module fedflow.core.message module fedflow.core.scheduler module fedflow.core.task module fedflow.core.taskgroup module

fedflow.mail module fedflow.mail.send_mail module fedflow.mail.templates module fedflow.units module fedflow.utils module fedflow.utils.data module fedflow.utils.trainer module FINISHED (fedflow.core.task.TaskStatus attribute) finished() (fedflow.core.taskgroup.TaskGroup method)

G

get_name() (fedflow.utils.ModuleUtils class method) get_task() (fedflow.core.taskgroup.TaskGroup method) global_ids (fedflow.core.taskgroup.TaskGroup attribute)

group_name (fedflow.core.taskgroup.TaskGroup property) group_template() (in module fedflow.mail.templates) groups (fedflow.FedFlow attribute) GroupScheduler (class in fedflow.core.scheduler)

H

handle() (fedflow.core.message.Handler method)

Handler (class in fedflow.core.message)

I

import_module() (fedflow.utils.ModuleUtils class method) INIT (fedflow.core.task.TaskStatus attribute)

INTERRUPT (fedflow.core.task.TaskStatus attribute) is_alive() (fedflow.core.task.Task method)

L

load() (fedflow.core.task.Task method) LOADING (fedflow.core.task.TaskStatus attribute) logger (fedflow.core.message.MessageListener attribute) (fedflow.core.scheduler.GroupScheduler attribute) (fedflow.mail.Mail attribute)

lr (fedflow.utils.trainer.SupervisedTrainer.History property)

M

Mail (class in fedflow.mail) main_logger (fedflow.core.task.Task attribute) memory_free() (fedflow.core.scheduler.GroupScheduler class method) Message (class in fedflow.core.message) MessageListener (class in fedflow.core.message) migrate_module() (fedflow.utils.ModuleUtils class method) module fedflow fedflow.config fedflow.context fedflow.core.message fedflow.core.scheduler fedflow.core.task fedflow.core.taskgroup fedflow.mail fedflow.mail.send_mail fedflow.mail.templates fedflow.units fedflow.utils fedflow.utils.data fedflow.utils.trainer

ModuleUtils (class in fedflow.utils) mount_dataloader() (fedflow.utils.trainer.SupervisedTrainer method) mount_dataset() (fedflow.utils.trainer.SupervisedTrainer method) move_task() (fedflow.core.taskgroup.TaskGroup method) mq() (fedflow.core.message.MessageListener class method)

N

numbers() (fedflow.core.taskgroup.TaskGroup method)

P

parse() (fedflow.units.ByteUnits class method) (fedflow.units.Units class method)

parse_memory_value() (fedflow.core.scheduler.GroupScheduler class method)

R

register_default_handler() (fedflow.core.message.MessageListener class method) register_handler() (fedflow.core.message.MessageListener class method) report_exception() (fedflow.core.taskgroup.TaskGroup method)

report_finish() (fedflow.core.taskgroup.TaskGroup method) retrieve_task() (fedflow.core.taskgroup.TaskGroup method) run() (fedflow.core.message.MessageListener class method) (fedflow.core.task.Task method)

S

schedule() (fedflow.core.scheduler.GroupScheduler class method) send_group_result() (fedflow.mail.Mail class method) send_mail() (in module fedflow.mail.send_mail) source (fedflow.core.message.Message property) start() (fedflow.core.message.MessageListener class method) (fedflow.core.task.Task method) (fedflow.FedFlow class method)

start_load() (fedflow.core.task.Task method) start_train() (fedflow.core.task.Task method) status (fedflow.core.task.Task property) stop() (fedflow.core.message.MessageListener class method) sub_logger (fedflow.core.task.Task attribute) SupervisedTrainer (class in fedflow.utils.trainer) SupervisedTrainer.History (class in fedflow.utils.trainer)

T

Task (class in fedflow.core.task) TaskGroup (class in fedflow.core.taskgroup) TaskStatus (class in fedflow.core.task) test() (fedflow.utils.trainer.SupervisedTrainer method) to_string() (fedflow.units.ByteUnits method) (fedflow.units.Units method)

train() (fedflow.core.task.Task method) (fedflow.utils.trainer.SupervisedTrainer method) train_acc (fedflow.utils.trainer.SupervisedTrainer.History property) train_loss (fedflow.utils.trainer.SupervisedTrainer.History property) TRAINING (fedflow.core.task.TaskStatus attribute)

U

Units (class in fedflow.units)

UNKNOWN (fedflow.core.task.TaskStatus attribute)

V

val_acc (fedflow.utils.trainer.SupervisedTrainer.History property)

val_loss (fedflow.utils.trainer.SupervisedTrainer.History property)

W

WAITING (fedflow.core.task.TaskStatus attribute)

workdir (fedflow.core.task.Task property) WorkDirContext (class in fedflow.context)