Skip to content

Commit

Permalink
format files
Browse files Browse the repository at this point in the history
  • Loading branch information
panh99 committed Oct 9, 2024
1 parent f02ca84 commit b372c42
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 6 deletions.
9 changes: 5 additions & 4 deletions src/py/flwr/client/connection/fleet_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,20 +16,21 @@


from typing import Any

from flwr.proto.fab_pb2 import GetFabRequest, GetFabResponse # pylint: disable=E0611
from flwr.proto.fleet_pb2 import ( # pylint: disable=E0611
CreateNodeRequest,
CreateNodeResponse,
DeleteNodeRequest,
DeleteNodeResponse,
PingRequest,
PingResponse,
PullTaskInsRequest,
DeleteNodeResponse,
PullTaskInsResponse,
PushTaskResRequest,
PushTaskResResponse,
PullTaskInsResponse,
)
from flwr.proto.run_pb2 import GetRunRequest, GetRunResponse # pylint: disable=E0611
from flwr.proto.fab_pb2 import GetFabRequest, GetFabResponse # pylint: disable=E0611


class FleetApi:
Expand Down Expand Up @@ -68,4 +69,4 @@ def GetRun( # pylint: disable=C0103
def GetFab( # pylint: disable=C0103
self, request: GetFabRequest, **kwargs: Any
) -> GetFabResponse:
"""Fleet.GetFab."""
"""Fleet.GetFab."""
Original file line number Diff line number Diff line change
Expand Up @@ -63,9 +63,9 @@
from flwr.proto.run_pb2 import GetRunRequest, GetRunResponse # pylint: disable=E0611
from flwr.proto.task_pb2 import TaskIns # pylint: disable=E0611

from ..fleet_api import FleetApi
from ..fleet_connection import FleetConnection
from .client_interceptor import AuthenticateClientInterceptor
from ..fleet_api import FleetApi


def on_channel_state_change(channel_connectivity: str) -> None:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,9 +63,9 @@
from flwr.proto.run_pb2 import GetRunRequest, GetRunResponse # pylint: disable=E0611
from flwr.proto.task_pb2 import TaskIns # pylint: disable=E0611

from ..fleet_api import FleetApi
from ..fleet_connection import FleetConnection
from .client_interceptor import AuthenticateClientInterceptor
from ..fleet_api import FleetApi


def on_channel_state_change(channel_connectivity: str) -> None:
Expand Down

0 comments on commit b372c42

Please sign in to comment.