nvflare.app_common.ccwf package

Subpackages

• nvflare.app_common.ccwf.comps package
  • Submodules
    • nvflare.app_common.ccwf.comps.cwe_result_printer module
      • CWEResultPrinter
    • nvflare.app_common.ccwf.comps.np_file_model_persistor module
      • NPFileModelPersistor
    • nvflare.app_common.ccwf.comps.np_trainer module
      • NPTrainer
    • nvflare.app_common.ccwf.comps.simple_intime_model_selector module
      • SimpleIntimeModelSelector
    • nvflare.app_common.ccwf.comps.simple_model_shareable_generator module
      • SimpleModelShareableGenerator
  • Module contents

Submodules

• nvflare.app_common.ccwf.ccwf_job module
  • CCWFJob
    • CCWFJob.add_cross_site_eval()
    • CCWFJob.add_cyclic()
    • CCWFJob.add_swarm()
  • CrossSiteEvalConfig
  • CyclicClientConfig
  • CyclicServerConfig
  • SwarmClientConfig
  • SwarmServerConfig
• nvflare.app_common.ccwf.client_controller_executor module
  • ClientControllerExecutor
    • ClientControllerExecutor.broadcast_final_result()
    • ClientControllerExecutor.execute()
    • ClientControllerExecutor.finalize()
    • ClientControllerExecutor.get_config_prop()
    • ClientControllerExecutor.handle_event()
    • ClientControllerExecutor.initialize()
    • ClientControllerExecutor.initialize_controller()
    • ClientControllerExecutor.is_task_secure()
    • ClientControllerExecutor.start_run()
    • ClientControllerExecutor.update_status()
• nvflare.app_common.ccwf.client_ctl module
  • ClientSideController
    • ClientSideController.broadcast_final_result()
    • ClientSideController.do_learn_task()
    • ClientSideController.execute()
    • ClientSideController.execute_learn_task()
    • ClientSideController.finalize()
    • ClientSideController.get_config_prop()
    • ClientSideController.handle_event()
    • ClientSideController.initialize()
    • ClientSideController.is_task_secure()
    • ClientSideController.process_config()
    • ClientSideController.record_last_result()
    • ClientSideController.send_learn_task()
    • ClientSideController.set_learn_task()
    • ClientSideController.start_run()
    • ClientSideController.start_workflow()
    • ClientSideController.topic_for_my_workflow()
    • ClientSideController.update_status()
• nvflare.app_common.ccwf.common module
  • Constant
    • Constant.ACTION
    • Constant.AGGREGATOR
    • Constant.AGGR_CLIENTS
    • Constant.ALL_DONE
    • Constant.BASENAME_ASK_FOR_MODEL
    • Constant.BASENAME_CONFIG
    • Constant.BASENAME_EVAL
    • Constant.BASENAME_LEARN
    • Constant.BASENAME_PREP_MODEL
    • Constant.BASENAME_REPORT_FINAL_RESULT
    • Constant.BASENAME_REPORT_LEARN_RESULT
    • Constant.BASENAME_START
    • Constant.CLIENT
    • Constant.CLIENTS
    • Constant.CLIENT_ORDER
    • Constant.CONFIG
    • Constant.CONFIG_TASK_TIMEOUT
    • Constant.END_WORKFLOW_TIMEOUT
    • Constant.ERROR
    • Constant.EVALUATEES
    • Constant.EVALUATORS
    • Constant.EVAL_GLOBAL
    • Constant.EVAL_LOCAL
    • Constant.EXECUTOR
    • Constant.EXECUTOR_FINALIZED
    • Constant.EXECUTOR_INITIALIZED
    • Constant.FINAL_RESULT_ACK_TIMEOUT
    • Constant.GET_MODEL_TIMEOUT
    • Constant.GLOBAL_CLIENT
    • Constant.GLOBAL_NAMES
    • Constant.JOB_STATUS_CHECK_INTERVAL
    • Constant.LAST_ROUND
    • Constant.LEARN_TASK_ABORT_TIMEOUT
    • Constant.LEARN_TASK_ACK_TIMEOUT
    • Constant.LEARN_TASK_CHECK_INTERVAL
    • Constant.MAX_TASK_TIMEOUT
    • Constant.METRIC
    • Constant.MODEL_NAME
    • Constant.MODEL_OWNER
    • Constant.MODEL_TYPE
    • Constant.ORDER
    • Constant.PER_CLIENT_STATUS_REPORT_TIMEOUT
    • Constant.PRIVATE_P2P
    • Constant.PROP_KEY_TRAIN_CLIENTS
    • Constant.RC_NO_GLOBAL_MODELS
    • Constant.RC_NO_LOCAL_MODEL
    • Constant.RC_UNABLE_TO_EVAL
    • Constant.RESULT
    • Constant.RESULT_CLIENTS
    • Constant.RESULT_TYPE
    • Constant.ROUND
    • Constant.START_CLIENT
    • Constant.START_ROUND
    • Constant.START_TASK_TIMEOUT
    • Constant.STATUS_REPORTS
    • Constant.TASK_CHECK_INTERVAL
    • Constant.TASK_NAME_PREFIX
    • Constant.TIMESTAMP
    • Constant.TN_PREFIX_CROSS_SITE_EVAL
    • Constant.TN_PREFIX_CYCLIC
    • Constant.TN_PREFIX_SWARM
    • Constant.TOPIC_END_WORKFLOW
    • Constant.TOPIC_SHARE_RESULT
    • Constant.TRAIN_CLIENTS
    • Constant.WORKFLOW_PROGRESS_TIMEOUT
  • CyclicOrder
    • CyclicOrder.FIXED
    • CyclicOrder.RANDOM
  • ModelType
    • ModelType.GLOBAL
    • ModelType.LOCAL
  • NumberMetricComparator
    • NumberMetricComparator.compare()
  • ResultType
    • ResultType.BEST
    • ResultType.LAST
  • StatusReport
    • StatusReport.to_dict()
  • make_task_name()
  • rotate_to_front()
  • status_report_from_dict()
  • topic_for_end_workflow()
• nvflare.app_common.ccwf.cse_client_ctl module
  • CrossSiteEvalClientController
    • CrossSiteEvalClientController.do_learn_task()
    • CrossSiteEvalClientController.execute()
    • CrossSiteEvalClientController.process_config()
    • CrossSiteEvalClientController.start_run()
    • CrossSiteEvalClientController.start_workflow()
• nvflare.app_common.ccwf.cse_server_ctl module
  • CrossSiteEvalServerController
    • CrossSiteEvalServerController.is_sub_flow_done()
    • CrossSiteEvalServerController.prepare_config()
    • CrossSiteEvalServerController.process_config_reply()
    • CrossSiteEvalServerController.start_controller()
    • CrossSiteEvalServerController.sub_flow()
• nvflare.app_common.ccwf.cyclic_client_ctl module
  • CyclicClientController
    • CyclicClientController.do_learn_task()
    • CyclicClientController.start_workflow()
• nvflare.app_common.ccwf.cyclic_server_ctl module
  • CyclicServerController
    • CyclicServerController.prepare_config()
• nvflare.app_common.ccwf.eval_gen module
  • EvalInclusionRC
    • EvalInclusionRC.CAN_INCLUDE
    • EvalInclusionRC.ENOUGH_ACTIONS_FOR_EVALUATEE
    • EvalInclusionRC.ENOUGH_ACTIONS_FOR_EVALUATOR
    • EvalInclusionRC.EVALUATOR_CONFLICT
  • parallel_eval_generator()
• nvflare.app_common.ccwf.server_ctl module
  • ClientStatus
  • ServerSideController
    • ServerSideController.client_started()
    • ServerSideController.control_flow()
    • ServerSideController.handle_event()
    • ServerSideController.is_sub_flow_done()
    • ServerSideController.prepare_config()
    • ServerSideController.process_config_reply()
    • ServerSideController.process_result_of_unknown_task()
    • ServerSideController.start_controller()
    • ServerSideController.stop_controller()
    • ServerSideController.sub_flow()
• nvflare.app_common.ccwf.swarm_client_ctl module
  • Gatherer
    • Gatherer.aggregate()
    • Gatherer.gather()
    • Gatherer.is_done()
  • SwarmClientController
    • SwarmClientController.do_learn_task()
    • SwarmClientController.execute()
    • SwarmClientController.handle_event()
    • SwarmClientController.process_config()
    • SwarmClientController.start_run()
    • SwarmClientController.start_workflow()
• nvflare.app_common.ccwf.swarm_server_ctl module
  • SwarmServerController
    • SwarmServerController.prepare_config()
    • SwarmServerController.start_controller()
• nvflare.app_common.ccwf.val_result_manager module
  • EvalResultManager
    • EvalResultManager.add_result()
    • EvalResultManager.get_results()

Module contents