Skip to content

Commit

Permalink
rename ClientController to TaskController
Browse files Browse the repository at this point in the history
  • Loading branch information
yanchengnv committed Sep 6, 2023
1 parent 13acc40 commit b272b4b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
from nvflare.security.logging import secure_format_exception


class ClientController(FLComponent, ControllerSpec):
class TaskController(FLComponent, ControllerSpec):
def __init__(
self,
) -> None:
Expand Down
6 changes: 3 additions & 3 deletions nvflare/app_common/ccwf/client_ctl.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
from nvflare.apis.executor import Executor
from nvflare.apis.fl_constant import FLContextKey, ReturnCode
from nvflare.apis.fl_context import FLContext
from nvflare.apis.impl.client_controller import ClientController, Task
from nvflare.apis.impl.task_controller import Task, TaskController
from nvflare.apis.shareable import Shareable, make_reply
from nvflare.apis.signal import Signal
from nvflare.app_common.abstract.learnable import Learnable
Expand All @@ -41,7 +41,7 @@ def __init__(self, task_name: str, task_data: Shareable, fl_ctx: FLContext):
self.abort_signal = Signal()


class ClientSideController(Executor, ClientController):
class ClientSideController(Executor, TaskController):
def __init__(
self,
task_name_prefix: str,
Expand Down Expand Up @@ -75,7 +75,7 @@ def __init__(
check_number_range("final_result_ack_timeout", final_result_ack_timeout, min_value=1.0)

Executor.__init__(self)
ClientController.__init__(self)
TaskController.__init__(self)
self.task_name_prefix = task_name_prefix
self.start_task_name = make_task_name(task_name_prefix, Constant.BASENAME_START)
self.configure_task_name = make_task_name(task_name_prefix, Constant.BASENAME_CONFIG)
Expand Down

0 comments on commit b272b4b

Please sign in to comment.