Skip to content

Commit

Permalink
rm extra messages
Browse files Browse the repository at this point in the history
  • Loading branch information
panh99 committed Sep 19, 2024
1 parent 470ee10 commit 65e7387
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 126 deletions.
17 changes: 0 additions & 17 deletions src/proto/flwr/proto/run.proto
Original file line number Diff line number Diff line change
Expand Up @@ -28,12 +28,6 @@ message Run {
string fab_hash = 5;
}

message StatusInfo {
string status = 1; // "starting", "running", "finished"
string sub_status = 2; // "completed", "failed", "stopped" or ""
string reason = 3; // failure reason
}

// CreateRun
message CreateRunRequest {
string fab_id = 1;
Expand All @@ -50,14 +44,3 @@ message CreateRunResponse {
// GetRun
message GetRunRequest { uint64 run_id = 1; }
message GetRunResponse { Run run = 1; }

// UpdateRunStatus
message UpdateRunStatusRequest {
uint64 run_id = 1;
StatusInfo info = 2;
}
message UpdateRunStatusResponse {}

// GetRunStatus
message GetRunStatusRequest { repeated uint64 run_ids = 1; }
message GetRunStatusResponse { map<uint64, StatusInfo> info_dict = 1; }
32 changes: 9 additions & 23 deletions src/py/flwr/proto/run_pb2.py

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

86 changes: 0 additions & 86 deletions src/py/flwr/proto/run_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -52,29 +52,6 @@ class Run(google.protobuf.message.Message):
def ClearField(self, field_name: typing_extensions.Literal["fab_hash",b"fab_hash","fab_id",b"fab_id","fab_version",b"fab_version","override_config",b"override_config","run_id",b"run_id"]) -> None: ...
global___Run = Run

class StatusInfo(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
STATUS_FIELD_NUMBER: builtins.int
SUB_STATUS_FIELD_NUMBER: builtins.int
REASON_FIELD_NUMBER: builtins.int
status: typing.Text
""""starting", "running", "finished" """

sub_status: typing.Text
""""completed", "failed", "stopped" or "" """

reason: typing.Text
"""failure reason"""

def __init__(self,
*,
status: typing.Text = ...,
sub_status: typing.Text = ...,
reason: typing.Text = ...,
) -> None: ...
def ClearField(self, field_name: typing_extensions.Literal["reason",b"reason","status",b"status","sub_status",b"sub_status"]) -> None: ...
global___StatusInfo = StatusInfo

class CreateRunRequest(google.protobuf.message.Message):
"""CreateRun"""
DESCRIPTOR: google.protobuf.descriptor.Descriptor
Expand Down Expand Up @@ -155,66 +132,3 @@ class GetRunResponse(google.protobuf.message.Message):
def HasField(self, field_name: typing_extensions.Literal["run",b"run"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["run",b"run"]) -> None: ...
global___GetRunResponse = GetRunResponse

class UpdateRunStatusRequest(google.protobuf.message.Message):
"""UpdateRunStatus"""
DESCRIPTOR: google.protobuf.descriptor.Descriptor
RUN_ID_FIELD_NUMBER: builtins.int
INFO_FIELD_NUMBER: builtins.int
run_id: builtins.int
@property
def info(self) -> global___StatusInfo: ...
def __init__(self,
*,
run_id: builtins.int = ...,
info: typing.Optional[global___StatusInfo] = ...,
) -> None: ...
def HasField(self, field_name: typing_extensions.Literal["info",b"info"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["info",b"info","run_id",b"run_id"]) -> None: ...
global___UpdateRunStatusRequest = UpdateRunStatusRequest

class UpdateRunStatusResponse(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
def __init__(self,
) -> None: ...
global___UpdateRunStatusResponse = UpdateRunStatusResponse

class GetRunStatusRequest(google.protobuf.message.Message):
"""GetRunStatus"""
DESCRIPTOR: google.protobuf.descriptor.Descriptor
RUN_IDS_FIELD_NUMBER: builtins.int
@property
def run_ids(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.int]: ...
def __init__(self,
*,
run_ids: typing.Optional[typing.Iterable[builtins.int]] = ...,
) -> None: ...
def ClearField(self, field_name: typing_extensions.Literal["run_ids",b"run_ids"]) -> None: ...
global___GetRunStatusRequest = GetRunStatusRequest

class GetRunStatusResponse(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
class InfoDictEntry(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
KEY_FIELD_NUMBER: builtins.int
VALUE_FIELD_NUMBER: builtins.int
key: builtins.int
@property
def value(self) -> global___StatusInfo: ...
def __init__(self,
*,
key: builtins.int = ...,
value: typing.Optional[global___StatusInfo] = ...,
) -> None: ...
def HasField(self, field_name: typing_extensions.Literal["value",b"value"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["key",b"key","value",b"value"]) -> None: ...

INFO_DICT_FIELD_NUMBER: builtins.int
@property
def info_dict(self) -> google.protobuf.internal.containers.MessageMap[builtins.int, global___StatusInfo]: ...
def __init__(self,
*,
info_dict: typing.Optional[typing.Mapping[builtins.int, global___StatusInfo]] = ...,
) -> None: ...
def ClearField(self, field_name: typing_extensions.Literal["info_dict",b"info_dict"]) -> None: ...
global___GetRunStatusResponse = GetRunStatusResponse

0 comments on commit 65e7387

Please sign in to comment.