diff --git a/src/proto/flwr/proto/exec.proto b/src/proto/flwr/proto/exec.proto index 851275c8ff0f..0804bd4bb5be 100644 --- a/src/proto/flwr/proto/exec.proto +++ b/src/proto/flwr/proto/exec.proto @@ -64,10 +64,19 @@ message ListRunsResponse { } message GetLoginDetailsRequest {} -message GetLoginDetailsResponse { map login_details = 1; } +message GetLoginDetailsResponse { + string auth_type = 1; + string device_code = 2; + string verification_uri_complete = 3; + int64 expires_in = 4; + int64 interval = 5; +} -message GetAuthTokensRequest { map auth_details = 1; } -message GetAuthTokensResponse { map auth_tokens = 1; } +message GetAuthTokensRequest { string device_code = 1; } +message GetAuthTokensResponse { + string access_token = 1; + string refresh_token = 2; +} message StopRunRequest { uint64 run_id = 1; } message StopRunResponse { bool success = 1; } diff --git a/src/py/flwr/proto/exec_pb2.py b/src/py/flwr/proto/exec_pb2.py index d3c508a8c6d9..1e4bcc498d39 100644 --- a/src/py/flwr/proto/exec_pb2.py +++ b/src/py/flwr/proto/exec_pb2.py @@ -18,7 +18,7 @@ from flwr.proto import run_pb2 as flwr_dot_proto_dot_run__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15\x66lwr/proto/exec.proto\x12\nflwr.proto\x1a\x14\x66lwr/proto/fab.proto\x1a\x1a\x66lwr/proto/transport.proto\x1a\x1a\x66lwr/proto/recordset.proto\x1a\x14\x66lwr/proto/run.proto\"\xfb\x01\n\x0fStartRunRequest\x12\x1c\n\x03\x66\x61\x62\x18\x01 \x01(\x0b\x32\x0f.flwr.proto.Fab\x12H\n\x0foverride_config\x18\x02 \x03(\x0b\x32/.flwr.proto.StartRunRequest.OverrideConfigEntry\x12\x35\n\x12\x66\x65\x64\x65ration_options\x18\x03 \x01(\x0b\x32\x19.flwr.proto.ConfigsRecord\x1aI\n\x13OverrideConfigEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\"2\n\x10StartRunResponse\x12\x13\n\x06run_id\x18\x01 \x01(\x04H\x00\x88\x01\x01\x42\t\n\x07_run_id\"<\n\x11StreamLogsRequest\x12\x0e\n\x06run_id\x18\x01 \x01(\x04\x12\x17\n\x0f\x61\x66ter_timestamp\x18\x02 \x01(\x01\"B\n\x12StreamLogsResponse\x12\x12\n\nlog_output\x18\x01 \x01(\t\x12\x18\n\x10latest_timestamp\x18\x02 \x01(\x01\"1\n\x0fListRunsRequest\x12\x13\n\x06run_id\x18\x01 \x01(\x04H\x00\x88\x01\x01\x42\t\n\x07_run_id\"\x9d\x01\n\x10ListRunsResponse\x12;\n\x08run_dict\x18\x01 \x03(\x0b\x32).flwr.proto.ListRunsResponse.RunDictEntry\x12\x0b\n\x03now\x18\x02 \x01(\t\x1a?\n\x0cRunDictEntry\x12\x0b\n\x03key\x18\x01 \x01(\x04\x12\x1e\n\x05value\x18\x02 \x01(\x0b\x32\x0f.flwr.proto.Run:\x02\x38\x01\"\x18\n\x16GetLoginDetailsRequest\"\x9c\x01\n\x17GetLoginDetailsResponse\x12L\n\rlogin_details\x18\x01 \x03(\x0b\x32\x35.flwr.proto.GetLoginDetailsResponse.LoginDetailsEntry\x1a\x33\n\x11LoginDetailsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x93\x01\n\x14GetAuthTokensRequest\x12G\n\x0c\x61uth_details\x18\x01 \x03(\x0b\x32\x31.flwr.proto.GetAuthTokensRequest.AuthDetailsEntry\x1a\x32\n\x10\x41uthDetailsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x92\x01\n\x15GetAuthTokensResponse\x12\x46\n\x0b\x61uth_tokens\x18\x01 \x03(\x0b\x32\x31.flwr.proto.GetAuthTokensResponse.AuthTokensEntry\x1a\x31\n\x0f\x41uthTokensEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\" \n\x0eStopRunRequest\x12\x0e\n\x06run_id\x18\x01 \x01(\x04\"\"\n\x0fStopRunResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x32\xe5\x03\n\x04\x45xec\x12G\n\x08StartRun\x12\x1b.flwr.proto.StartRunRequest\x1a\x1c.flwr.proto.StartRunResponse\"\x00\x12\x44\n\x07StopRun\x12\x1a.flwr.proto.StopRunRequest\x1a\x1b.flwr.proto.StopRunResponse\"\x00\x12O\n\nStreamLogs\x12\x1d.flwr.proto.StreamLogsRequest\x1a\x1e.flwr.proto.StreamLogsResponse\"\x00\x30\x01\x12G\n\x08ListRuns\x12\x1b.flwr.proto.ListRunsRequest\x1a\x1c.flwr.proto.ListRunsResponse\"\x00\x12\\\n\x0fGetLoginDetails\x12\".flwr.proto.GetLoginDetailsRequest\x1a#.flwr.proto.GetLoginDetailsResponse\"\x00\x12V\n\rGetAuthTokens\x12 .flwr.proto.GetAuthTokensRequest\x1a!.flwr.proto.GetAuthTokensResponse\"\x00\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15\x66lwr/proto/exec.proto\x12\nflwr.proto\x1a\x14\x66lwr/proto/fab.proto\x1a\x1a\x66lwr/proto/transport.proto\x1a\x1a\x66lwr/proto/recordset.proto\x1a\x14\x66lwr/proto/run.proto\"\xfb\x01\n\x0fStartRunRequest\x12\x1c\n\x03\x66\x61\x62\x18\x01 \x01(\x0b\x32\x0f.flwr.proto.Fab\x12H\n\x0foverride_config\x18\x02 \x03(\x0b\x32/.flwr.proto.StartRunRequest.OverrideConfigEntry\x12\x35\n\x12\x66\x65\x64\x65ration_options\x18\x03 \x01(\x0b\x32\x19.flwr.proto.ConfigsRecord\x1aI\n\x13OverrideConfigEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\"2\n\x10StartRunResponse\x12\x13\n\x06run_id\x18\x01 \x01(\x04H\x00\x88\x01\x01\x42\t\n\x07_run_id\"<\n\x11StreamLogsRequest\x12\x0e\n\x06run_id\x18\x01 \x01(\x04\x12\x17\n\x0f\x61\x66ter_timestamp\x18\x02 \x01(\x01\"B\n\x12StreamLogsResponse\x12\x12\n\nlog_output\x18\x01 \x01(\t\x12\x18\n\x10latest_timestamp\x18\x02 \x01(\x01\"1\n\x0fListRunsRequest\x12\x13\n\x06run_id\x18\x01 \x01(\x04H\x00\x88\x01\x01\x42\t\n\x07_run_id\"\x9d\x01\n\x10ListRunsResponse\x12;\n\x08run_dict\x18\x01 \x03(\x0b\x32).flwr.proto.ListRunsResponse.RunDictEntry\x12\x0b\n\x03now\x18\x02 \x01(\t\x1a?\n\x0cRunDictEntry\x12\x0b\n\x03key\x18\x01 \x01(\x04\x12\x1e\n\x05value\x18\x02 \x01(\x0b\x32\x0f.flwr.proto.Run:\x02\x38\x01\"\x18\n\x16GetLoginDetailsRequest\"\x8a\x01\n\x17GetLoginDetailsResponse\x12\x11\n\tauth_type\x18\x01 \x01(\t\x12\x13\n\x0b\x64\x65vice_code\x18\x02 \x01(\t\x12!\n\x19verification_uri_complete\x18\x03 \x01(\t\x12\x12\n\nexpires_in\x18\x04 \x01(\x03\x12\x10\n\x08interval\x18\x05 \x01(\x03\"+\n\x14GetAuthTokensRequest\x12\x13\n\x0b\x64\x65vice_code\x18\x01 \x01(\t\"D\n\x15GetAuthTokensResponse\x12\x14\n\x0c\x61\x63\x63\x65ss_token\x18\x01 \x01(\t\x12\x15\n\rrefresh_token\x18\x02 \x01(\t\" \n\x0eStopRunRequest\x12\x0e\n\x06run_id\x18\x01 \x01(\x04\"\"\n\x0fStopRunResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x32\xe5\x03\n\x04\x45xec\x12G\n\x08StartRun\x12\x1b.flwr.proto.StartRunRequest\x1a\x1c.flwr.proto.StartRunResponse\"\x00\x12\x44\n\x07StopRun\x12\x1a.flwr.proto.StopRunRequest\x1a\x1b.flwr.proto.StopRunResponse\"\x00\x12O\n\nStreamLogs\x12\x1d.flwr.proto.StreamLogsRequest\x1a\x1e.flwr.proto.StreamLogsResponse\"\x00\x30\x01\x12G\n\x08ListRuns\x12\x1b.flwr.proto.ListRunsRequest\x1a\x1c.flwr.proto.ListRunsResponse\"\x00\x12\\\n\x0fGetLoginDetails\x12\".flwr.proto.GetLoginDetailsRequest\x1a#.flwr.proto.GetLoginDetailsResponse\"\x00\x12V\n\rGetAuthTokens\x12 .flwr.proto.GetAuthTokensRequest\x1a!.flwr.proto.GetAuthTokensResponse\"\x00\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -29,12 +29,6 @@ _globals['_STARTRUNREQUEST_OVERRIDECONFIGENTRY']._serialized_options = b'8\001' _globals['_LISTRUNSRESPONSE_RUNDICTENTRY']._options = None _globals['_LISTRUNSRESPONSE_RUNDICTENTRY']._serialized_options = b'8\001' - _globals['_GETLOGINDETAILSRESPONSE_LOGINDETAILSENTRY']._options = None - _globals['_GETLOGINDETAILSRESPONSE_LOGINDETAILSENTRY']._serialized_options = b'8\001' - _globals['_GETAUTHTOKENSREQUEST_AUTHDETAILSENTRY']._options = None - _globals['_GETAUTHTOKENSREQUEST_AUTHDETAILSENTRY']._serialized_options = b'8\001' - _globals['_GETAUTHTOKENSRESPONSE_AUTHTOKENSENTRY']._options = None - _globals['_GETAUTHTOKENSRESPONSE_AUTHTOKENSENTRY']._serialized_options = b'8\001' _globals['_STARTRUNREQUEST']._serialized_start=138 _globals['_STARTRUNREQUEST']._serialized_end=389 _globals['_STARTRUNREQUEST_OVERRIDECONFIGENTRY']._serialized_start=316 @@ -54,21 +48,15 @@ _globals['_GETLOGINDETAILSREQUEST']._serialized_start=784 _globals['_GETLOGINDETAILSREQUEST']._serialized_end=808 _globals['_GETLOGINDETAILSRESPONSE']._serialized_start=811 - _globals['_GETLOGINDETAILSRESPONSE']._serialized_end=967 - _globals['_GETLOGINDETAILSRESPONSE_LOGINDETAILSENTRY']._serialized_start=916 - _globals['_GETLOGINDETAILSRESPONSE_LOGINDETAILSENTRY']._serialized_end=967 - _globals['_GETAUTHTOKENSREQUEST']._serialized_start=970 - _globals['_GETAUTHTOKENSREQUEST']._serialized_end=1117 - _globals['_GETAUTHTOKENSREQUEST_AUTHDETAILSENTRY']._serialized_start=1067 - _globals['_GETAUTHTOKENSREQUEST_AUTHDETAILSENTRY']._serialized_end=1117 - _globals['_GETAUTHTOKENSRESPONSE']._serialized_start=1120 - _globals['_GETAUTHTOKENSRESPONSE']._serialized_end=1266 - _globals['_GETAUTHTOKENSRESPONSE_AUTHTOKENSENTRY']._serialized_start=1217 - _globals['_GETAUTHTOKENSRESPONSE_AUTHTOKENSENTRY']._serialized_end=1266 - _globals['_STOPRUNREQUEST']._serialized_start=1268 - _globals['_STOPRUNREQUEST']._serialized_end=1300 - _globals['_STOPRUNRESPONSE']._serialized_start=1302 - _globals['_STOPRUNRESPONSE']._serialized_end=1336 - _globals['_EXEC']._serialized_start=1339 - _globals['_EXEC']._serialized_end=1824 + _globals['_GETLOGINDETAILSRESPONSE']._serialized_end=949 + _globals['_GETAUTHTOKENSREQUEST']._serialized_start=951 + _globals['_GETAUTHTOKENSREQUEST']._serialized_end=994 + _globals['_GETAUTHTOKENSRESPONSE']._serialized_start=996 + _globals['_GETAUTHTOKENSRESPONSE']._serialized_end=1064 + _globals['_STOPRUNREQUEST']._serialized_start=1066 + _globals['_STOPRUNREQUEST']._serialized_end=1098 + _globals['_STOPRUNRESPONSE']._serialized_start=1100 + _globals['_STOPRUNRESPONSE']._serialized_end=1134 + _globals['_EXEC']._serialized_start=1137 + _globals['_EXEC']._serialized_end=1622 # @@protoc_insertion_point(module_scope) diff --git a/src/py/flwr/proto/exec_pb2.pyi b/src/py/flwr/proto/exec_pb2.pyi index d77aa26e1aa0..576f4322b316 100644 --- a/src/py/flwr/proto/exec_pb2.pyi +++ b/src/py/flwr/proto/exec_pb2.pyi @@ -143,77 +143,50 @@ global___GetLoginDetailsRequest = GetLoginDetailsRequest class GetLoginDetailsResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor - class LoginDetailsEntry(google.protobuf.message.Message): - DESCRIPTOR: google.protobuf.descriptor.Descriptor - KEY_FIELD_NUMBER: builtins.int - VALUE_FIELD_NUMBER: builtins.int - key: typing.Text - value: typing.Text - def __init__(self, - *, - key: typing.Text = ..., - value: typing.Text = ..., - ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["key",b"key","value",b"value"]) -> None: ... - - LOGIN_DETAILS_FIELD_NUMBER: builtins.int - @property - def login_details(self) -> google.protobuf.internal.containers.ScalarMap[typing.Text, typing.Text]: ... + AUTH_TYPE_FIELD_NUMBER: builtins.int + DEVICE_CODE_FIELD_NUMBER: builtins.int + VERIFICATION_URI_COMPLETE_FIELD_NUMBER: builtins.int + EXPIRES_IN_FIELD_NUMBER: builtins.int + INTERVAL_FIELD_NUMBER: builtins.int + auth_type: typing.Text + device_code: typing.Text + verification_uri_complete: typing.Text + expires_in: builtins.int + interval: builtins.int def __init__(self, *, - login_details: typing.Optional[typing.Mapping[typing.Text, typing.Text]] = ..., + auth_type: typing.Text = ..., + device_code: typing.Text = ..., + verification_uri_complete: typing.Text = ..., + expires_in: builtins.int = ..., + interval: builtins.int = ..., ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["login_details",b"login_details"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["auth_type",b"auth_type","device_code",b"device_code","expires_in",b"expires_in","interval",b"interval","verification_uri_complete",b"verification_uri_complete"]) -> None: ... global___GetLoginDetailsResponse = GetLoginDetailsResponse class GetAuthTokensRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor - class AuthDetailsEntry(google.protobuf.message.Message): - DESCRIPTOR: google.protobuf.descriptor.Descriptor - KEY_FIELD_NUMBER: builtins.int - VALUE_FIELD_NUMBER: builtins.int - key: typing.Text - value: typing.Text - def __init__(self, - *, - key: typing.Text = ..., - value: typing.Text = ..., - ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["key",b"key","value",b"value"]) -> None: ... - - AUTH_DETAILS_FIELD_NUMBER: builtins.int - @property - def auth_details(self) -> google.protobuf.internal.containers.ScalarMap[typing.Text, typing.Text]: ... + DEVICE_CODE_FIELD_NUMBER: builtins.int + device_code: typing.Text def __init__(self, *, - auth_details: typing.Optional[typing.Mapping[typing.Text, typing.Text]] = ..., + device_code: typing.Text = ..., ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["auth_details",b"auth_details"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["device_code",b"device_code"]) -> None: ... global___GetAuthTokensRequest = GetAuthTokensRequest class GetAuthTokensResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor - class AuthTokensEntry(google.protobuf.message.Message): - DESCRIPTOR: google.protobuf.descriptor.Descriptor - KEY_FIELD_NUMBER: builtins.int - VALUE_FIELD_NUMBER: builtins.int - key: typing.Text - value: typing.Text - def __init__(self, - *, - key: typing.Text = ..., - value: typing.Text = ..., - ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["key",b"key","value",b"value"]) -> None: ... - - AUTH_TOKENS_FIELD_NUMBER: builtins.int - @property - def auth_tokens(self) -> google.protobuf.internal.containers.ScalarMap[typing.Text, typing.Text]: ... + ACCESS_TOKEN_FIELD_NUMBER: builtins.int + REFRESH_TOKEN_FIELD_NUMBER: builtins.int + access_token: typing.Text + refresh_token: typing.Text def __init__(self, *, - auth_tokens: typing.Optional[typing.Mapping[typing.Text, typing.Text]] = ..., + access_token: typing.Text = ..., + refresh_token: typing.Text = ..., ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["auth_tokens",b"auth_tokens"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["access_token",b"access_token","refresh_token",b"refresh_token"]) -> None: ... global___GetAuthTokensResponse = GetAuthTokensResponse class StopRunRequest(google.protobuf.message.Message):