flip.nvflare.controllers.init_training ====================================== .. py:module:: flip.nvflare.controllers.init_training Classes ------- .. autoapisummary:: flip.nvflare.controllers.init_training.InitTraining Module Contents --------------- .. py:class:: InitTraining(model_id: str = '', min_clients: int = FlipConstants.MIN_CLIENTS, flip: flip.FLIP = FLIP(), cleanup_timeout: int = 600) Bases: :py:obj:`nvflare.apis.impl.controller.Controller` .. py:attribute:: _model_id_fallback :value: '' .. py:attribute:: _model_id :type: str | None :value: None .. py:attribute:: _min_clients .. py:attribute:: flip .. py:attribute:: _cleanup_timeout :value: 600 .. py:method:: _resolve_model_id(fl_ctx: nvflare.apis.fl_context.FLContext) -> str .. py:method:: start_controller(fl_ctx: nvflare.apis.fl_context.FLContext) -> None .. py:method:: control_flow(abort_signal: nvflare.apis.signal.Signal, fl_ctx: nvflare.apis.fl_context.FLContext) -> None .. py:method:: stop_controller(fl_ctx: nvflare.apis.fl_context.FLContext) -> None .. py:method:: process_result_of_unknown_task(client: nvflare.apis.client.Client, task_name: str, client_task_id: str, result: nvflare.apis.shareable.Shareable, fl_ctx: nvflare.apis.fl_context.FLContext) -> None .. py:method:: _set_init_training_status(fl_ctx: nvflare.apis.fl_context.FLContext) -> None .. py:method:: _check_abort_signal(fl_ctx: nvflare.apis.fl_context.FLContext, abort_signal: nvflare.apis.signal.Signal) -> bool .. py:method:: _process_cleanup_result(client_task: nvflare.apis.controller_spec.ClientTask, fl_ctx: nvflare.apis.fl_context.FLContext) -> None .. py:method:: _accept_cleanup_result(client_name: str, result: nvflare.apis.shareable.Shareable, fl_ctx: nvflare.apis.fl_context.FLContext) -> bool | None