Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
# ==============================================================================
"""Flower App Scheduler."""


from .plugin import SchedulerPlugin

__all__ = [
"SchedulerPlugin",
]
"""Flower SuperExec."""
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,13 @@
# See the License for the specific language governing permissions and
# limitations under the License.
# ==============================================================================
"""Flower ClientApp Scheduler."""
"""Flower SuperExec plugins."""


from .simple_clientapp_scheduler_plugin import SimpleClientAppSchedulerPlugin
from .clientapp_exec_plugin import ClientAppExecPlugin
from .exec_plugin import ExecPlugin

__all__ = [
"SimpleClientAppSchedulerPlugin",
"ClientAppExecPlugin",
"ExecPlugin",
]
Original file line number Diff line number Diff line change
Expand Up @@ -12,19 +12,19 @@
# See the License for the specific language governing permissions and
# limitations under the License.
# ==============================================================================
"""Simple Flower ClientApp Scheduler plugin."""
"""Simple Flower SuperExec plugin for ClientApp."""


import os
import subprocess
from collections.abc import Sequence
from typing import Optional

from flwr.supercore.scheduler import SchedulerPlugin
from .exec_plugin import ExecPlugin


class SimpleClientAppSchedulerPlugin(SchedulerPlugin):
"""Simple Flower ClientApp Scheduler plugin.
class ClientAppExecPlugin(ExecPlugin):
"""Simple Flower SuperExec plugin for ClientApp.

The plugin always selects the first candidate run ID.
"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
# ==============================================================================
"""Abstract base class SchedulerPlugin."""
"""Abstract base class ExecPlugin."""


from abc import ABC, abstractmethod
Expand All @@ -22,8 +22,8 @@
from flwr.common.typing import Run


class SchedulerPlugin(ABC):
"""Abstract base class for Scheduler plugins."""
class ExecPlugin(ABC):
"""Abstract base class for SuperExec plugins."""

def __init__(
self,
Expand Down Expand Up @@ -59,7 +59,7 @@ def launch_app(self, token: str, run_id: int) -> None:
This method starts the application process using the given `token`.
The `run_id` is used solely for bookkeeping purposes, allowing any
scheduler implementation to associate this launch with a specific run.
plugin implementation to associate this launch with a specific run.
Parameters
----------
Expand Down
Loading