nvflare.apis.impl package

Submodules

• nvflare.apis.impl.any_relay_manager module
  • AnyRelayTaskManager
    • AnyRelayTaskManager.check_task_exit()
    • AnyRelayTaskManager.check_task_result()
    • AnyRelayTaskManager.check_task_send()
• nvflare.apis.impl.bcast_manager module
  • BcastForeverTaskManager
    • BcastForeverTaskManager.check_task_exit()
    • BcastForeverTaskManager.check_task_send()
  • BcastTaskManager
    • BcastTaskManager.check_task_exit()
• nvflare.apis.impl.controller module
  • Controller
    • Controller.add_to_fed_job()
    • Controller.broadcast()
    • Controller.broadcast_and_wait()
    • Controller.broadcast_forever()
    • Controller.cancel_all_tasks()
    • Controller.cancel_task()
    • Controller.get_client_disconnect_time()
    • Controller.get_num_standing_tasks()
    • Controller.initialize()
    • Controller.relay()
    • Controller.relay_and_wait()
    • Controller.send()
    • Controller.send_and_wait()
    • Controller.set_communicator()
• nvflare.apis.impl.job_def_manager module
  • JobInfo
  • SimpleJobDefManager
    • SimpleJobDefManager.clone()
    • SimpleJobDefManager.create()
    • SimpleJobDefManager.delete()
    • SimpleJobDefManager.get_all_jobs()
    • SimpleJobDefManager.get_app()
    • SimpleJobDefManager.get_content()
    • SimpleJobDefManager.get_job()
    • SimpleJobDefManager.get_jobs_by_status()
    • SimpleJobDefManager.get_jobs_to_schedule()
    • SimpleJobDefManager.get_jobs_waiting_for_review()
    • SimpleJobDefManager.get_storage_component()
    • SimpleJobDefManager.get_storage_for_download()
    • SimpleJobDefManager.job_uri()
    • SimpleJobDefManager.refresh_meta()
    • SimpleJobDefManager.save_workspace()
    • SimpleJobDefManager.set_approval()
    • SimpleJobDefManager.set_results_uri()
    • SimpleJobDefManager.set_status()
    • SimpleJobDefManager.update_meta()
• nvflare.apis.impl.send_manager module
  • SendTaskManager
    • SendTaskManager.check_task_exit()
    • SendTaskManager.check_task_send()
• nvflare.apis.impl.seq_relay_manager module
  • SequentialRelayTaskManager
    • SequentialRelayTaskManager.check_task_exit()
    • SequentialRelayTaskManager.check_task_result()
    • SequentialRelayTaskManager.check_task_send()
• nvflare.apis.impl.task_controller module
  • TaskController
    • TaskController.broadcast()
    • TaskController.broadcast_and_wait()
    • TaskController.control_flow()
    • TaskController.handle_event()
    • TaskController.process_result_of_unknown_task()
    • TaskController.send()
    • TaskController.send_and_wait()
    • TaskController.start_controller()
    • TaskController.stop_controller()
• nvflare.apis.impl.task_manager module
  • TaskCheckStatus
    • TaskCheckStatus.BLOCK
    • TaskCheckStatus.NO_BLOCK
    • TaskCheckStatus.SEND
  • TaskManager
    • TaskManager.check_task_exit()
    • TaskManager.check_task_result()
    • TaskManager.check_task_send()
• nvflare.apis.impl.wf_comm_client module
  • WFCommClient
    • WFCommClient.broadcast()
    • WFCommClient.broadcast_and_wait()
    • WFCommClient.relay()
    • WFCommClient.relay_and_wait()
    • WFCommClient.send()
    • WFCommClient.send_and_wait()
• nvflare.apis.impl.wf_comm_server module
  • WFCommServer
    • WFCommServer.broadcast()
    • WFCommServer.broadcast_and_wait()
    • WFCommServer.broadcast_forever()
    • WFCommServer.cancel_all_tasks()
    • WFCommServer.cancel_task()
    • WFCommServer.check_tasks()
    • WFCommServer.client_is_active()
    • WFCommServer.finalize_run()
    • WFCommServer.get_client_disconnect_time()
    • WFCommServer.get_num_standing_tasks()
    • WFCommServer.handle_event()
    • WFCommServer.handle_exception()
    • WFCommServer.initialize_run()
    • WFCommServer.process_dead_client_report()
    • WFCommServer.process_submission()
    • WFCommServer.process_task_check()
    • WFCommServer.process_task_request()
    • WFCommServer.relay()
    • WFCommServer.relay_and_wait()
    • WFCommServer.send()
    • WFCommServer.send_and_wait()
    • WFCommServer.wait_for_task()

Module contents