nvflare.app_common.workflows package

Subpackages

• nvflare.app_common.workflows.lr package
  • Submodules
    • nvflare.app_common.workflows.lr.fedavg module
      • FedAvgLR
    • nvflare.app_common.workflows.lr.np_persistor module
      • LRModelPersistor
  • Module contents

Submodules

• nvflare.app_common.workflows.base_fedavg module
  • BaseFedAvg
    • BaseFedAvg.aggregate()
    • BaseFedAvg.aggregate_fn()
    • BaseFedAvg.update_model()
• nvflare.app_common.workflows.base_model_controller module
  • BaseModelController
    • BaseModelController.broadcast_model()
    • BaseModelController.build_component()
    • BaseModelController.control_flow()
    • BaseModelController.get_app_dir()
    • BaseModelController.get_component()
    • BaseModelController.get_run_dir()
    • BaseModelController.load_model()
    • BaseModelController.process_result_of_unknown_task()
    • BaseModelController.run()
    • BaseModelController.sample_clients()
    • BaseModelController.save_model()
    • BaseModelController.set_fl_context()
    • BaseModelController.start_controller()
    • BaseModelController.stop_controller()
• nvflare.app_common.workflows.broadcast_and_process module
  • BroadcastAndProcess
    • BroadcastAndProcess.control_flow()
    • BroadcastAndProcess.process_result_of_unknown_task()
    • BroadcastAndProcess.start_controller()
    • BroadcastAndProcess.stop_controller()
• nvflare.app_common.workflows.broadcast_operator module
  • BroadcastAndWait
    • BroadcastAndWait.broadcast_and_wait()
    • BroadcastAndWait.get_tasks()
    • BroadcastAndWait.multicasts_and_wait()
    • BroadcastAndWait.results_cb()
    • BroadcastAndWait.update_result()
• nvflare.app_common.workflows.cmd_task_controller module
  • CmdTaskController
    • CmdTaskController.run()
    • CmdTaskController.send_task_and_wait()
• nvflare.app_common.workflows.cross_site_eval module
  • CrossSiteEval
    • CrossSiteEval.initialize()
    • CrossSiteEval.run()
    • CrossSiteEval.save_results()
    • CrossSiteEval.track_results()
• nvflare.app_common.workflows.cross_site_model_eval module
  • CrossSiteModelEval
    • CrossSiteModelEval.control_flow()
    • CrossSiteModelEval.handle_event()
    • CrossSiteModelEval.process_result_of_unknown_task()
    • CrossSiteModelEval.start_controller()
    • CrossSiteModelEval.stop_controller()
• nvflare.app_common.workflows.cyclic module
  • Cyclic
    • Cyclic.run()
• nvflare.app_common.workflows.cyclic_ctl module
  • CyclicController
    • CyclicController.control_flow()
    • CyclicController.get_persist_state()
    • CyclicController.process_result_of_unknown_task()
    • CyclicController.restore()
    • CyclicController.start_controller()
    • CyclicController.stop_controller()
  • RelayOrder
    • RelayOrder.FIXED
    • RelayOrder.RANDOM
    • RelayOrder.RANDOM_WITHOUT_SAME_IN_A_ROW
• nvflare.app_common.workflows.error_handling_controller module
  • ErrorHandlingController
    • ErrorHandlingController.handle_client_errors()
• nvflare.app_common.workflows.etl_controller module
  • ETLController
• nvflare.app_common.workflows.fedavg module
  • FedAvg
    • FedAvg.is_curr_model_better()
    • FedAvg.load_model()
    • FedAvg.load_model_file()
    • FedAvg.run()
    • FedAvg.save_model()
    • FedAvg.save_model_file()
    • FedAvg.should_stop()
• nvflare.app_common.workflows.global_model_eval module
  • GlobalModelEval
• nvflare.app_common.workflows.hierarchical_statistics_controller module
  • HierarchicalStatisticsController
    • HierarchicalStatisticsController.statistics_task_flow()
• nvflare.app_common.workflows.initialize_global_weights module
  • InitializeGlobalWeights
• nvflare.app_common.workflows.model_controller module
  • ModelController
    • ModelController.load_model()
    • ModelController.run()
    • ModelController.sample_clients()
    • ModelController.save_model()
    • ModelController.send_model()
    • ModelController.send_model_and_wait()
• nvflare.app_common.workflows.scaffold module
  • Scaffold
    • Scaffold.initialize()
    • Scaffold.run()
  • scaffold_aggregate_fn()
• nvflare.app_common.workflows.scatter_and_gather module
  • ScatterAndGather
    • ScatterAndGather.control_flow()
    • ScatterAndGather.get_persist_state()
    • ScatterAndGather.handle_event()
    • ScatterAndGather.process_result_of_unknown_task()
    • ScatterAndGather.restore()
    • ScatterAndGather.start_controller()
    • ScatterAndGather.stop_controller()
• nvflare.app_common.workflows.scatter_and_gather_scaffold module
  • ScatterAndGatherScaffold
    • ScatterAndGatherScaffold.control_flow()
    • ScatterAndGatherScaffold.start_controller()
• nvflare.app_common.workflows.splitnn_workflow module
  • SplitNNConstants
    • SplitNNConstants.BATCH_INDICES
    • SplitNNConstants.BATCH_SIZE
    • SplitNNConstants.DATA
    • SplitNNConstants.TARGET_NAMES
    • SplitNNConstants.TASK_INIT_MODEL
    • SplitNNConstants.TASK_RESULT
    • SplitNNConstants.TASK_TRAIN
    • SplitNNConstants.TASK_TRAIN_LABEL_STEP
    • SplitNNConstants.TASK_VALID_LABEL_STEP
    • SplitNNConstants.TIMEOUT
  • SplitNNController
    • SplitNNController.control_flow()
    • SplitNNController.handle_event()
    • SplitNNController.process_result_of_unknown_task()
    • SplitNNController.start_controller()
    • SplitNNController.stop_controller()
  • SplitNNDataKind
    • SplitNNDataKind.ACTIVATIONS
    • SplitNNDataKind.GRADIENT
• nvflare.app_common.workflows.statistics_controller module
  • StatisticsController
    • StatisticsController.control_flow()
    • StatisticsController.handle_client_errors()
    • StatisticsController.post_fn()
    • StatisticsController.pre_run_task_flow()
    • StatisticsController.process_result_of_unknown_task()
    • StatisticsController.results_cb()
    • StatisticsController.results_pre_run_cb()
    • StatisticsController.start_controller()
    • StatisticsController.statistics_task_flow()
    • StatisticsController.stop_controller()

Module contents