diff --git a/projects/fal/src/fal/cli/apps.py b/projects/fal/src/fal/cli/apps.py index 0b5be746..5a5ed3a6 100644 --- a/projects/fal/src/fal/cli/apps.py +++ b/projects/fal/src/fal/cli/apps.py @@ -221,7 +221,7 @@ def _runners(args): str(runner.in_flight_requests), ( "N/A (active)" - if not runner.expiration_countdown + if runner.expiration_countdown is None else f"{runner.expiration_countdown}s" ), f"{runner.uptime} ({runner.uptime.total_seconds()}s)", diff --git a/projects/fal/src/fal/sdk.py b/projects/fal/src/fal/sdk.py index 7f5768b4..70f75bb0 100644 --- a/projects/fal/src/fal/sdk.py +++ b/projects/fal/src/fal/sdk.py @@ -5,7 +5,7 @@ from dataclasses import dataclass, field from datetime import datetime, timedelta from enum import Enum -from typing import Any, Callable, Generic, Iterator, Literal, TypeVar +from typing import Any, Callable, Generic, Iterator, Literal, Optional, TypeVar import grpc import isolate_proto @@ -214,7 +214,7 @@ class AliasInfo: class RunnerInfo: runner_id: str in_flight_requests: int - expiration_countdown: int + expiration_countdown: Optional[int] uptime: timedelta @@ -344,7 +344,9 @@ def _from_grpc_runner_info(message: isolate_proto.RunnerInfo) -> RunnerInfo: return RunnerInfo( runner_id=message.runner_id, in_flight_requests=message.in_flight_requests, - expiration_countdown=message.expiration_countdown, + expiration_countdown=message.expiration_countdown + if message.HasField("expiration_countdown") + else None, uptime=timedelta(seconds=message.uptime), ) diff --git a/projects/isolate_proto/src/isolate_proto/controller.proto b/projects/isolate_proto/src/isolate_proto/controller.proto index a876fa5f..cc72eb2b 100644 --- a/projects/isolate_proto/src/isolate_proto/controller.proto +++ b/projects/isolate_proto/src/isolate_proto/controller.proto @@ -309,6 +309,6 @@ message ListAliasRunnersResponse { message RunnerInfo { string runner_id = 1; int32 in_flight_requests = 2; - int32 expiration_countdown = 3; + optional int32 expiration_countdown = 3; float uptime = 4; } diff --git a/projects/isolate_proto/src/isolate_proto/controller_pb2.py b/projects/isolate_proto/src/isolate_proto/controller_pb2.py index 9e96a12d..4faef95a 100644 --- a/projects/isolate_proto/src/isolate_proto/controller_pb2.py +++ b/projects/isolate_proto/src/isolate_proto/controller_pb2.py @@ -19,7 +19,7 @@ from google.protobuf import struct_pb2 as google_dot_protobuf_dot_struct__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x63ontroller.proto\x12\ncontroller\x1a\x0c\x63ommon.proto\x1a\x0cserver.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1cgoogle/protobuf/struct.proto\"\xde\x01\n\tHostedMap\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12!\n\x06inputs\x18\x04 \x03(\x0b\x32\x11.SerializedObjectB\x17\n\x15_machine_requirements\"\xf6\x01\n\tHostedRun\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_func\"\x88\x01\n\x14\x43reateUserKeyRequest\x12\x35\n\x05scope\x18\x01 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\x12\n\x05\x61lias\x18\x02 \x01(\tH\x00\x88\x01\x01\"\x1b\n\x05Scope\x12\t\n\x05\x41\x44MIN\x10\x00\x12\x07\n\x03\x41PI\x10\x01\x42\x08\n\x06_alias\";\n\x15\x43reateUserKeyResponse\x12\x12\n\nkey_secret\x18\x01 \x01(\t\x12\x0e\n\x06key_id\x18\x02 \x01(\t\"\x15\n\x13ListUserKeysRequest\"B\n\x14ListUserKeysResponse\x12*\n\tuser_keys\x18\x01 \x03(\x0b\x32\x17.controller.UserKeyInfo\"&\n\x14RevokeUserKeyRequest\x12\x0e\n\x06key_id\x18\x01 \x01(\t\"\x17\n\x15RevokeUserKeyResponse\"\x93\x01\n\x0bUserKeyInfo\x12\x0e\n\x06key_id\x18\x01 \x01(\t\x12.\n\ncreated_at\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x35\n\x05scope\x18\x03 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\r\n\x05\x61lias\x18\x04 \x01(\t\"\xb1\x01\n\x0fHostedRunResult\x12\x0e\n\x06run_id\x18\x01 \x01(\t\x12\x30\n\x06status\x18\x02 \x01(\x0b\x32\x1b.controller.HostedRunStatusH\x00\x88\x01\x01\x12\x12\n\x04logs\x18\x03 \x03(\x0b\x32\x04.Log\x12,\n\x0creturn_value\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\t\n\x07_statusB\x0f\n\r_return_value\"\x80\x01\n\x0fHostedRunStatus\x12\x30\n\x05state\x18\x01 \x01(\x0e\x32!.controller.HostedRunStatus.State\";\n\x05State\x12\x0f\n\x0bIN_PROGRESS\x10\x00\x12\x0b\n\x07SUCCESS\x10\x01\x12\x14\n\x10INTERNAL_FAILURE\x10\x02\"\xbb\x04\n\x13MachineRequirements\x12\x1d\n\x0cmachine_type\x18\x01 \x01(\tB\x02\x18\x01H\x00\x88\x01\x01\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x01\x88\x01\x01\x12\x17\n\nbase_image\x18\x03 \x01(\tH\x02\x88\x01\x01\x12\x19\n\x0c\x65xposed_port\x18\x04 \x01(\x05H\x03\x88\x01\x01\x12\x16\n\tscheduler\x18\x05 \x01(\tH\x04\x88\x01\x01\x12\x37\n\x11scheduler_options\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x06 \x01(\x05H\x06\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\t \x01(\x05H\x07\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\n \x01(\x05H\x08\x88\x01\x01\x12\x15\n\rmachine_types\x18\x0b \x03(\t\x12\x15\n\x08num_gpus\x18\x0c \x01(\x05H\t\x88\x01\x01\x12\x1c\n\x0frequest_timeout\x18\r \x01(\x05H\n\x88\x01\x01\x42\x0f\n\r_machine_typeB\r\n\x0b_keep_aliveB\r\n\x0b_base_imageB\x0f\n\r_exposed_portB\x0c\n\n_schedulerB\x14\n\x12_scheduler_optionsB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrencyB\x0b\n\t_num_gpusB\x12\n\x10_request_timeout\"\xed\x04\n\x1aRegisterApplicationRequest\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x12\x1d\n\x10\x61pplication_name\x18\x05 \x01(\tH\x02\x88\x01\x01\x12\x37\n\tauth_mode\x18\x06 \x01(\x0e\x32\x1f.controller.ApplicationAuthModeH\x03\x88\x01\x01\x12 \n\x0fmax_concurrency\x18\x07 \x01(\x05\x42\x02\x18\x01H\x04\x88\x01\x01\x12.\n\x08metadata\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12@\n\x13\x64\x65ployment_strategy\x18\t \x01(\x0e\x32\x1e.controller.DeploymentStrategyH\x06\x88\x01\x01\x12\x12\n\x05scale\x18\n \x01(\x08H\x07\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_funcB\x13\n\x11_application_nameB\x0c\n\n_auth_modeB\x12\n\x10_max_concurrencyB\x0b\n\t_metadataB\x16\n\x14_deployment_strategyB\x08\n\x06_scale\"7\n\x1dRegisterApplicationResultType\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"z\n\x19RegisterApplicationResult\x12\x12\n\x04logs\x18\x01 \x03(\x0b\x32\x04.Log\x12>\n\x06result\x18\x02 \x01(\x0b\x32).controller.RegisterApplicationResultTypeH\x00\x88\x01\x01\x42\t\n\x07_result\"\xf4\x01\n\x18UpdateApplicationRequest\x12\x18\n\x10\x61pplication_name\x18\x01 \x01(\t\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x00\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x03 \x01(\x05H\x01\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\x04 \x01(\x05H\x02\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\x05 \x01(\x05H\x03\x88\x01\x01\x42\r\n\x0b_keep_aliveB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrency\"D\n\x17UpdateApplicationResult\x12)\n\nalias_info\x18\x01 \x01(\x0b\x32\x15.controller.AliasInfo\"\x19\n\x17ListApplicationsRequest\"\xa1\x01\n\x0f\x41pplicationInfo\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\x12\x17\n\x0fmax_concurrency\x18\x02 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x03 \x01(\x05\x12\x12\n\nkeep_alive\x18\x04 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x06 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x07 \x01(\x05\"K\n\x16ListApplicationsResult\x12\x31\n\x0c\x61pplications\x18\x01 \x03(\x0b\x32\x1b.controller.ApplicationInfo\"2\n\x18\x44\x65leteApplicationRequest\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"\x19\n\x17\x44\x65leteApplicationResult\"f\n\x0fSetAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\"\x10\n\x0eSetAliasResult\"#\n\x12\x44\x65leteAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"%\n\x11\x44\x65leteAliasResult\x12\x10\n\x08revision\x18\x01 \x01(\t\"\x14\n\x12ListAliasesRequest\";\n\x11ListAliasesResult\x12&\n\x07\x61liases\x18\x01 \x03(\x0b\x32\x15.controller.AliasInfo\"\xd8\x01\n\tAliasInfo\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\x12\x17\n\x0fmax_concurrency\x18\x04 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x05 \x01(\x05\x12\x12\n\nkeep_alive\x18\x06 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x07 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x08 \x01(\x05\">\n\x10SetSecretRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x12\n\x05value\x18\x02 \x01(\tH\x00\x88\x01\x01\x42\x08\n\x06_value\"\x13\n\x11SetSecretResponse\"\x14\n\x12ListSecretsRequest\"^\n\x06Secret\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x35\n\x0c\x63reated_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x88\x01\x01\x42\x0f\n\r_created_time\":\n\x13ListSecretsResponse\x12#\n\x07secrets\x18\x01 \x03(\x0b\x32\x12.controller.Secret\"(\n\x17ListAliasRunnersRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"C\n\x18ListAliasRunnersResponse\x12\'\n\x07runners\x18\x01 \x03(\x0b\x32\x16.controller.RunnerInfo\"i\n\nRunnerInfo\x12\x11\n\trunner_id\x18\x01 \x01(\t\x12\x1a\n\x12in_flight_requests\x18\x02 \x01(\x05\x12\x1c\n\x14\x65xpiration_countdown\x18\x03 \x01(\x05\x12\x0e\n\x06uptime\x18\x04 \x01(\x02*:\n\x13\x41pplicationAuthMode\x12\x0b\n\x07PRIVATE\x10\x00\x12\n\n\x06PUBLIC\x10\x01\x12\n\n\x06SHARED\x10\x02*/\n\x12\x44\x65ploymentStrategy\x12\x0c\n\x08RECREATE\x10\x00\x12\x0b\n\x07ROLLING\x10\x01\x32\x89\n\n\x11IsolateController\x12=\n\x03Run\x12\x15.controller.HostedRun\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12=\n\x03Map\x12\x15.controller.HostedMap\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12V\n\rCreateUserKey\x12 .controller.CreateUserKeyRequest\x1a!.controller.CreateUserKeyResponse\"\x00\x12S\n\x0cListUserKeys\x12\x1f.controller.ListUserKeysRequest\x1a .controller.ListUserKeysResponse\"\x00\x12V\n\rRevokeUserKey\x12 .controller.RevokeUserKeyRequest\x1a!.controller.RevokeUserKeyResponse\"\x00\x12h\n\x13RegisterApplication\x12&.controller.RegisterApplicationRequest\x1a%.controller.RegisterApplicationResult\"\x00\x30\x01\x12`\n\x11UpdateApplication\x12$.controller.UpdateApplicationRequest\x1a#.controller.UpdateApplicationResult\"\x00\x12]\n\x10ListApplications\x12#.controller.ListApplicationsRequest\x1a\".controller.ListApplicationsResult\"\x00\x12`\n\x11\x44\x65leteApplication\x12$.controller.DeleteApplicationRequest\x1a#.controller.DeleteApplicationResult\"\x00\x12\x45\n\x08SetAlias\x12\x1b.controller.SetAliasRequest\x1a\x1a.controller.SetAliasResult\"\x00\x12N\n\x0b\x44\x65leteAlias\x12\x1e.controller.DeleteAliasRequest\x1a\x1d.controller.DeleteAliasResult\"\x00\x12N\n\x0bListAliases\x12\x1e.controller.ListAliasesRequest\x1a\x1d.controller.ListAliasesResult\"\x00\x12J\n\tSetSecret\x12\x1c.controller.SetSecretRequest\x1a\x1d.controller.SetSecretResponse\"\x00\x12P\n\x0bListSecrets\x12\x1e.controller.ListSecretsRequest\x1a\x1f.controller.ListSecretsResponse\"\x00\x12_\n\x10ListAliasRunners\x12#.controller.ListAliasRunnersRequest\x1a$.controller.ListAliasRunnersResponse\"\x00\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x63ontroller.proto\x12\ncontroller\x1a\x0c\x63ommon.proto\x1a\x0cserver.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1cgoogle/protobuf/struct.proto\"\xde\x01\n\tHostedMap\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12!\n\x06inputs\x18\x04 \x03(\x0b\x32\x11.SerializedObjectB\x17\n\x15_machine_requirements\"\xf6\x01\n\tHostedRun\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_func\"\x88\x01\n\x14\x43reateUserKeyRequest\x12\x35\n\x05scope\x18\x01 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\x12\n\x05\x61lias\x18\x02 \x01(\tH\x00\x88\x01\x01\"\x1b\n\x05Scope\x12\t\n\x05\x41\x44MIN\x10\x00\x12\x07\n\x03\x41PI\x10\x01\x42\x08\n\x06_alias\";\n\x15\x43reateUserKeyResponse\x12\x12\n\nkey_secret\x18\x01 \x01(\t\x12\x0e\n\x06key_id\x18\x02 \x01(\t\"\x15\n\x13ListUserKeysRequest\"B\n\x14ListUserKeysResponse\x12*\n\tuser_keys\x18\x01 \x03(\x0b\x32\x17.controller.UserKeyInfo\"&\n\x14RevokeUserKeyRequest\x12\x0e\n\x06key_id\x18\x01 \x01(\t\"\x17\n\x15RevokeUserKeyResponse\"\x93\x01\n\x0bUserKeyInfo\x12\x0e\n\x06key_id\x18\x01 \x01(\t\x12.\n\ncreated_at\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x35\n\x05scope\x18\x03 \x01(\x0e\x32&.controller.CreateUserKeyRequest.Scope\x12\r\n\x05\x61lias\x18\x04 \x01(\t\"\xb1\x01\n\x0fHostedRunResult\x12\x0e\n\x06run_id\x18\x01 \x01(\t\x12\x30\n\x06status\x18\x02 \x01(\x0b\x32\x1b.controller.HostedRunStatusH\x00\x88\x01\x01\x12\x12\n\x04logs\x18\x03 \x03(\x0b\x32\x04.Log\x12,\n\x0creturn_value\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x42\t\n\x07_statusB\x0f\n\r_return_value\"\x80\x01\n\x0fHostedRunStatus\x12\x30\n\x05state\x18\x01 \x01(\x0e\x32!.controller.HostedRunStatus.State\";\n\x05State\x12\x0f\n\x0bIN_PROGRESS\x10\x00\x12\x0b\n\x07SUCCESS\x10\x01\x12\x14\n\x10INTERNAL_FAILURE\x10\x02\"\xbb\x04\n\x13MachineRequirements\x12\x1d\n\x0cmachine_type\x18\x01 \x01(\tB\x02\x18\x01H\x00\x88\x01\x01\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x01\x88\x01\x01\x12\x17\n\nbase_image\x18\x03 \x01(\tH\x02\x88\x01\x01\x12\x19\n\x0c\x65xposed_port\x18\x04 \x01(\x05H\x03\x88\x01\x01\x12\x16\n\tscheduler\x18\x05 \x01(\tH\x04\x88\x01\x01\x12\x37\n\x11scheduler_options\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x06 \x01(\x05H\x06\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\t \x01(\x05H\x07\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\n \x01(\x05H\x08\x88\x01\x01\x12\x15\n\rmachine_types\x18\x0b \x03(\t\x12\x15\n\x08num_gpus\x18\x0c \x01(\x05H\t\x88\x01\x01\x12\x1c\n\x0frequest_timeout\x18\r \x01(\x05H\n\x88\x01\x01\x42\x0f\n\r_machine_typeB\r\n\x0b_keep_aliveB\r\n\x0b_base_imageB\x0f\n\r_exposed_portB\x0c\n\n_schedulerB\x14\n\x12_scheduler_optionsB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrencyB\x0b\n\t_num_gpusB\x12\n\x10_request_timeout\"\xed\x04\n\x1aRegisterApplicationRequest\x12,\n\x0c\x65nvironments\x18\x01 \x03(\x0b\x32\x16.EnvironmentDefinition\x12\x42\n\x14machine_requirements\x18\x02 \x01(\x0b\x32\x1f.controller.MachineRequirementsH\x00\x88\x01\x01\x12#\n\x08\x66unction\x18\x03 \x01(\x0b\x32\x11.SerializedObject\x12*\n\nsetup_func\x18\x04 \x01(\x0b\x32\x11.SerializedObjectH\x01\x88\x01\x01\x12\x1d\n\x10\x61pplication_name\x18\x05 \x01(\tH\x02\x88\x01\x01\x12\x37\n\tauth_mode\x18\x06 \x01(\x0e\x32\x1f.controller.ApplicationAuthModeH\x03\x88\x01\x01\x12 \n\x0fmax_concurrency\x18\x07 \x01(\x05\x42\x02\x18\x01H\x04\x88\x01\x01\x12.\n\x08metadata\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructH\x05\x88\x01\x01\x12@\n\x13\x64\x65ployment_strategy\x18\t \x01(\x0e\x32\x1e.controller.DeploymentStrategyH\x06\x88\x01\x01\x12\x12\n\x05scale\x18\n \x01(\x08H\x07\x88\x01\x01\x42\x17\n\x15_machine_requirementsB\r\n\x0b_setup_funcB\x13\n\x11_application_nameB\x0c\n\n_auth_modeB\x12\n\x10_max_concurrencyB\x0b\n\t_metadataB\x16\n\x14_deployment_strategyB\x08\n\x06_scale\"7\n\x1dRegisterApplicationResultType\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"z\n\x19RegisterApplicationResult\x12\x12\n\x04logs\x18\x01 \x03(\x0b\x32\x04.Log\x12>\n\x06result\x18\x02 \x01(\x0b\x32).controller.RegisterApplicationResultTypeH\x00\x88\x01\x01\x42\t\n\x07_result\"\xf4\x01\n\x18UpdateApplicationRequest\x12\x18\n\x10\x61pplication_name\x18\x01 \x01(\t\x12\x17\n\nkeep_alive\x18\x02 \x01(\x05H\x00\x88\x01\x01\x12\x1d\n\x10max_multiplexing\x18\x03 \x01(\x05H\x01\x88\x01\x01\x12\x1c\n\x0fmax_concurrency\x18\x04 \x01(\x05H\x02\x88\x01\x01\x12\x1c\n\x0fmin_concurrency\x18\x05 \x01(\x05H\x03\x88\x01\x01\x42\r\n\x0b_keep_aliveB\x13\n\x11_max_multiplexingB\x12\n\x10_max_concurrencyB\x12\n\x10_min_concurrency\"D\n\x17UpdateApplicationResult\x12)\n\nalias_info\x18\x01 \x01(\x0b\x32\x15.controller.AliasInfo\"\x19\n\x17ListApplicationsRequest\"\xa1\x01\n\x0f\x41pplicationInfo\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\x12\x17\n\x0fmax_concurrency\x18\x02 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x03 \x01(\x05\x12\x12\n\nkeep_alive\x18\x04 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x06 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x07 \x01(\x05\"K\n\x16ListApplicationsResult\x12\x31\n\x0c\x61pplications\x18\x01 \x03(\x0b\x32\x1b.controller.ApplicationInfo\"2\n\x18\x44\x65leteApplicationRequest\x12\x16\n\x0e\x61pplication_id\x18\x01 \x01(\t\"\x19\n\x17\x44\x65leteApplicationResult\"f\n\x0fSetAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\"\x10\n\x0eSetAliasResult\"#\n\x12\x44\x65leteAliasRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"%\n\x11\x44\x65leteAliasResult\x12\x10\n\x08revision\x18\x01 \x01(\t\"\x14\n\x12ListAliasesRequest\";\n\x11ListAliasesResult\x12&\n\x07\x61liases\x18\x01 \x03(\x0b\x32\x15.controller.AliasInfo\"\xd8\x01\n\tAliasInfo\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x10\n\x08revision\x18\x02 \x01(\t\x12\x32\n\tauth_mode\x18\x03 \x01(\x0e\x32\x1f.controller.ApplicationAuthMode\x12\x17\n\x0fmax_concurrency\x18\x04 \x01(\x05\x12\x18\n\x10max_multiplexing\x18\x05 \x01(\x05\x12\x12\n\nkeep_alive\x18\x06 \x01(\x05\x12\x16\n\x0e\x61\x63tive_runners\x18\x07 \x01(\x05\x12\x17\n\x0fmin_concurrency\x18\x08 \x01(\x05\">\n\x10SetSecretRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x12\n\x05value\x18\x02 \x01(\tH\x00\x88\x01\x01\x42\x08\n\x06_value\"\x13\n\x11SetSecretResponse\"\x14\n\x12ListSecretsRequest\"^\n\x06Secret\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x35\n\x0c\x63reated_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x88\x01\x01\x42\x0f\n\r_created_time\":\n\x13ListSecretsResponse\x12#\n\x07secrets\x18\x01 \x03(\x0b\x32\x12.controller.Secret\"(\n\x17ListAliasRunnersRequest\x12\r\n\x05\x61lias\x18\x01 \x01(\t\"C\n\x18ListAliasRunnersResponse\x12\'\n\x07runners\x18\x01 \x03(\x0b\x32\x16.controller.RunnerInfo\"\x87\x01\n\nRunnerInfo\x12\x11\n\trunner_id\x18\x01 \x01(\t\x12\x1a\n\x12in_flight_requests\x18\x02 \x01(\x05\x12!\n\x14\x65xpiration_countdown\x18\x03 \x01(\x05H\x00\x88\x01\x01\x12\x0e\n\x06uptime\x18\x04 \x01(\x02\x42\x17\n\x15_expiration_countdown*:\n\x13\x41pplicationAuthMode\x12\x0b\n\x07PRIVATE\x10\x00\x12\n\n\x06PUBLIC\x10\x01\x12\n\n\x06SHARED\x10\x02*/\n\x12\x44\x65ploymentStrategy\x12\x0c\n\x08RECREATE\x10\x00\x12\x0b\n\x07ROLLING\x10\x01\x32\x89\n\n\x11IsolateController\x12=\n\x03Run\x12\x15.controller.HostedRun\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12=\n\x03Map\x12\x15.controller.HostedMap\x1a\x1b.controller.HostedRunResult\"\x00\x30\x01\x12V\n\rCreateUserKey\x12 .controller.CreateUserKeyRequest\x1a!.controller.CreateUserKeyResponse\"\x00\x12S\n\x0cListUserKeys\x12\x1f.controller.ListUserKeysRequest\x1a .controller.ListUserKeysResponse\"\x00\x12V\n\rRevokeUserKey\x12 .controller.RevokeUserKeyRequest\x1a!.controller.RevokeUserKeyResponse\"\x00\x12h\n\x13RegisterApplication\x12&.controller.RegisterApplicationRequest\x1a%.controller.RegisterApplicationResult\"\x00\x30\x01\x12`\n\x11UpdateApplication\x12$.controller.UpdateApplicationRequest\x1a#.controller.UpdateApplicationResult\"\x00\x12]\n\x10ListApplications\x12#.controller.ListApplicationsRequest\x1a\".controller.ListApplicationsResult\"\x00\x12`\n\x11\x44\x65leteApplication\x12$.controller.DeleteApplicationRequest\x1a#.controller.DeleteApplicationResult\"\x00\x12\x45\n\x08SetAlias\x12\x1b.controller.SetAliasRequest\x1a\x1a.controller.SetAliasResult\"\x00\x12N\n\x0b\x44\x65leteAlias\x12\x1e.controller.DeleteAliasRequest\x1a\x1d.controller.DeleteAliasResult\"\x00\x12N\n\x0bListAliases\x12\x1e.controller.ListAliasesRequest\x1a\x1d.controller.ListAliasesResult\"\x00\x12J\n\tSetSecret\x12\x1c.controller.SetSecretRequest\x1a\x1d.controller.SetSecretResponse\"\x00\x12P\n\x0bListSecrets\x12\x1e.controller.ListSecretsRequest\x1a\x1f.controller.ListSecretsResponse\"\x00\x12_\n\x10ListAliasRunners\x12#.controller.ListAliasRunnersRequest\x1a$.controller.ListAliasRunnersResponse\"\x00\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -30,10 +30,10 @@ _globals['_MACHINEREQUIREMENTS'].fields_by_name['machine_type']._serialized_options = b'\030\001' _globals['_REGISTERAPPLICATIONREQUEST'].fields_by_name['max_concurrency']._loaded_options = None _globals['_REGISTERAPPLICATIONREQUEST'].fields_by_name['max_concurrency']._serialized_options = b'\030\001' - _globals['_APPLICATIONAUTHMODE']._serialized_start=4470 - _globals['_APPLICATIONAUTHMODE']._serialized_end=4528 - _globals['_DEPLOYMENTSTRATEGY']._serialized_start=4530 - _globals['_DEPLOYMENTSTRATEGY']._serialized_end=4577 + _globals['_APPLICATIONAUTHMODE']._serialized_start=4501 + _globals['_APPLICATIONAUTHMODE']._serialized_end=4559 + _globals['_DEPLOYMENTSTRATEGY']._serialized_start=4561 + _globals['_DEPLOYMENTSTRATEGY']._serialized_end=4608 _globals['_HOSTEDMAP']._serialized_start=156 _globals['_HOSTEDMAP']._serialized_end=378 _globals['_HOSTEDRUN']._serialized_start=381 @@ -110,8 +110,8 @@ _globals['_LISTALIASRUNNERSREQUEST']._serialized_end=4292 _globals['_LISTALIASRUNNERSRESPONSE']._serialized_start=4294 _globals['_LISTALIASRUNNERSRESPONSE']._serialized_end=4361 - _globals['_RUNNERINFO']._serialized_start=4363 - _globals['_RUNNERINFO']._serialized_end=4468 - _globals['_ISOLATECONTROLLER']._serialized_start=4580 - _globals['_ISOLATECONTROLLER']._serialized_end=5869 + _globals['_RUNNERINFO']._serialized_start=4364 + _globals['_RUNNERINFO']._serialized_end=4499 + _globals['_ISOLATECONTROLLER']._serialized_start=4611 + _globals['_ISOLATECONTROLLER']._serialized_end=5900 # @@protoc_insertion_point(module_scope) diff --git a/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi b/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi index b700049d..e071cc61 100644 --- a/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi +++ b/projects/isolate_proto/src/isolate_proto/controller_pb2.pyi @@ -2,7 +2,6 @@ @generated by mypy-protobuf. Do not edit manually! isort:skip_file """ - import builtins import collections.abc from isolate.connections.grpc.definitions import common_pb2 @@ -55,7 +54,7 @@ RECREATE: DeploymentStrategy.ValueType # 0 ROLLING: DeploymentStrategy.ValueType # 1 global___DeploymentStrategy = DeploymentStrategy -@typing.final +@typing_extensions.final class HostedMap(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -66,19 +65,15 @@ class HostedMap(google.protobuf.message.Message): @property def environments(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[server_pb2.EnvironmentDefinition]: """Environment definitions.""" - @property def machine_requirements(self) -> global___MachineRequirements: """Machine requirements""" - @property def function(self) -> common_pb2.SerializedObject: """Function to run.""" - @property def inputs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[common_pb2.SerializedObject]: """Inputs to the function""" - def __init__( self, *, @@ -87,13 +82,13 @@ class HostedMap(google.protobuf.message.Message): function: common_pb2.SerializedObject | None = ..., inputs: collections.abc.Iterable[common_pb2.SerializedObject] | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "function", b"function", "machine_requirements", b"machine_requirements"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "environments", b"environments", "function", b"function", "inputs", b"inputs", "machine_requirements", b"machine_requirements"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_machine_requirements", b"_machine_requirements"]) -> typing.Literal["machine_requirements"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "function", b"function", "machine_requirements", b"machine_requirements"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "environments", b"environments", "function", b"function", "inputs", b"inputs", "machine_requirements", b"machine_requirements"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_requirements", b"_machine_requirements"]) -> typing_extensions.Literal["machine_requirements"] | None: ... global___HostedMap = HostedMap -@typing.final +@typing_extensions.final class HostedRun(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -104,19 +99,15 @@ class HostedRun(google.protobuf.message.Message): @property def environments(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[server_pb2.EnvironmentDefinition]: """Environment definitions.""" - @property def machine_requirements(self) -> global___MachineRequirements: """Machine requirements""" - @property def function(self) -> common_pb2.SerializedObject: """Function to run.""" - @property def setup_func(self) -> common_pb2.SerializedObject: """Optional setup function to pass as the first argument to the function.""" - def __init__( self, *, @@ -125,16 +116,16 @@ class HostedRun(google.protobuf.message.Message): function: common_pb2.SerializedObject | None = ..., setup_func: common_pb2.SerializedObject | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_machine_requirements", b"_machine_requirements", "_setup_func", b"_setup_func", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "setup_func", b"setup_func"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_machine_requirements", b"_machine_requirements"]) -> typing.Literal["machine_requirements"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_requirements", b"_machine_requirements"]) -> typing_extensions.Literal["machine_requirements"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_setup_func", b"_setup_func"]) -> typing.Literal["setup_func"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_setup_func", b"_setup_func"]) -> typing_extensions.Literal["setup_func"] | None: ... global___HostedRun = HostedRun -@typing.final +@typing_extensions.final class CreateUserKeyRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -163,13 +154,13 @@ class CreateUserKeyRequest(google.protobuf.message.Message): scope: global___CreateUserKeyRequest.Scope.ValueType = ..., alias: builtins.str | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_alias", b"_alias", "alias", b"alias"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_alias", b"_alias", "alias", b"alias", "scope", b"scope"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_alias", b"_alias"]) -> typing.Literal["alias"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_alias", b"_alias", "alias", b"alias"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_alias", b"_alias", "alias", b"alias", "scope", b"scope"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_alias", b"_alias"]) -> typing_extensions.Literal["alias"] | None: ... global___CreateUserKeyRequest = CreateUserKeyRequest -@typing.final +@typing_extensions.final class CreateUserKeyResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -183,11 +174,11 @@ class CreateUserKeyResponse(google.protobuf.message.Message): key_secret: builtins.str = ..., key_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["key_id", b"key_id", "key_secret", b"key_secret"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["key_id", b"key_id", "key_secret", b"key_secret"]) -> None: ... global___CreateUserKeyResponse = CreateUserKeyResponse -@typing.final +@typing_extensions.final class ListUserKeysRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -199,7 +190,7 @@ class ListUserKeysRequest(google.protobuf.message.Message): global___ListUserKeysRequest = ListUserKeysRequest -@typing.final +@typing_extensions.final class ListUserKeysResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -211,11 +202,11 @@ class ListUserKeysResponse(google.protobuf.message.Message): *, user_keys: collections.abc.Iterable[global___UserKeyInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["user_keys", b"user_keys"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["user_keys", b"user_keys"]) -> None: ... global___ListUserKeysResponse = ListUserKeysResponse -@typing.final +@typing_extensions.final class RevokeUserKeyRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -226,11 +217,11 @@ class RevokeUserKeyRequest(google.protobuf.message.Message): *, key_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["key_id", b"key_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["key_id", b"key_id"]) -> None: ... global___RevokeUserKeyRequest = RevokeUserKeyRequest -@typing.final +@typing_extensions.final class RevokeUserKeyResponse(google.protobuf.message.Message): """Empty. For future use.""" @@ -242,7 +233,7 @@ class RevokeUserKeyResponse(google.protobuf.message.Message): global___RevokeUserKeyResponse = RevokeUserKeyResponse -@typing.final +@typing_extensions.final class UserKeyInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -251,10 +242,10 @@ class UserKeyInfo(google.protobuf.message.Message): SCOPE_FIELD_NUMBER: builtins.int ALIAS_FIELD_NUMBER: builtins.int key_id: builtins.str - scope: global___CreateUserKeyRequest.Scope.ValueType - alias: builtins.str @property def created_at(self) -> google.protobuf.timestamp_pb2.Timestamp: ... + scope: global___CreateUserKeyRequest.Scope.ValueType + alias: builtins.str def __init__( self, *, @@ -263,12 +254,12 @@ class UserKeyInfo(google.protobuf.message.Message): scope: global___CreateUserKeyRequest.Scope.ValueType = ..., alias: builtins.str = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["created_at", b"created_at"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias", "created_at", b"created_at", "key_id", b"key_id", "scope", b"scope"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["created_at", b"created_at"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias", "created_at", b"created_at", "key_id", b"key_id", "scope", b"scope"]) -> None: ... global___UserKeyInfo = UserKeyInfo -@typing.final +@typing_extensions.final class HostedRunResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -283,17 +274,14 @@ class HostedRunResult(google.protobuf.message.Message): """Optionally the status of the current run (in terms of fal cloud). """ - @property def logs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[common_pb2.Log]: """The most recent logs from the run.""" - @property def return_value(self) -> common_pb2.SerializedObject: """The result of the run, if it is complete (indicated by status.is_complete). """ - def __init__( self, *, @@ -302,16 +290,16 @@ class HostedRunResult(google.protobuf.message.Message): logs: collections.abc.Iterable[common_pb2.Log] | None = ..., return_value: common_pb2.SerializedObject | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_return_value", b"_return_value", "_status", b"_status", "return_value", b"return_value", "status", b"status"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_return_value", b"_return_value", "_status", b"_status", "logs", b"logs", "return_value", b"return_value", "run_id", b"run_id", "status", b"status"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_return_value", b"_return_value", "_status", b"_status", "return_value", b"return_value", "status", b"status"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_return_value", b"_return_value", "_status", b"_status", "logs", b"logs", "return_value", b"return_value", "run_id", b"run_id", "status", b"status"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_return_value", b"_return_value"]) -> typing.Literal["return_value"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_return_value", b"_return_value"]) -> typing_extensions.Literal["return_value"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_status", b"_status"]) -> typing.Literal["status"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_status", b"_status"]) -> typing_extensions.Literal["status"] | None: ... global___HostedRunResult = HostedRunResult -@typing.final +@typing_extensions.final class HostedRunStatus(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -348,11 +336,11 @@ class HostedRunStatus(google.protobuf.message.Message): *, state: global___HostedRunStatus.State.ValueType = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["state", b"state"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["state", b"state"]) -> None: ... global___HostedRunStatus = HostedRunStatus -@typing.final +@typing_extensions.final class MachineRequirements(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -380,17 +368,16 @@ class MachineRequirements(google.protobuf.message.Message): base_image: builtins.str exposed_port: builtins.int scheduler: builtins.str + @property + def scheduler_options(self) -> google.protobuf.struct_pb2.Struct: ... max_multiplexing: builtins.int max_concurrency: builtins.int min_concurrency: builtins.int - num_gpus: builtins.int - request_timeout: builtins.int - @property - def scheduler_options(self) -> google.protobuf.struct_pb2.Struct: ... @property def machine_types(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: """machine_type alternative""" - + num_gpus: builtins.int + request_timeout: builtins.int def __init__( self, *, @@ -407,34 +394,34 @@ class MachineRequirements(google.protobuf.message.Message): num_gpus: builtins.int | None = ..., request_timeout: builtins.int | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_base_image", b"_base_image", "_exposed_port", b"_exposed_port", "_keep_alive", b"_keep_alive", "_machine_type", b"_machine_type", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "_num_gpus", b"_num_gpus", "_request_timeout", b"_request_timeout", "_scheduler", b"_scheduler", "_scheduler_options", b"_scheduler_options", "base_image", b"base_image", "exposed_port", b"exposed_port", "keep_alive", b"keep_alive", "machine_type", b"machine_type", "machine_types", b"machine_types", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "num_gpus", b"num_gpus", "request_timeout", b"request_timeout", "scheduler", b"scheduler", "scheduler_options", b"scheduler_options"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_base_image", b"_base_image"]) -> typing.Literal["base_image"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_base_image", b"_base_image"]) -> typing_extensions.Literal["base_image"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_exposed_port", b"_exposed_port"]) -> typing.Literal["exposed_port"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_exposed_port", b"_exposed_port"]) -> typing_extensions.Literal["exposed_port"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_keep_alive", b"_keep_alive"]) -> typing.Literal["keep_alive"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_keep_alive", b"_keep_alive"]) -> typing_extensions.Literal["keep_alive"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_machine_type", b"_machine_type"]) -> typing.Literal["machine_type"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_type", b"_machine_type"]) -> typing_extensions.Literal["machine_type"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_concurrency", b"_max_concurrency"]) -> typing.Literal["max_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_concurrency", b"_max_concurrency"]) -> typing_extensions.Literal["max_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing.Literal["max_multiplexing"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing_extensions.Literal["max_multiplexing"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_min_concurrency", b"_min_concurrency"]) -> typing.Literal["min_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_min_concurrency", b"_min_concurrency"]) -> typing_extensions.Literal["min_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_num_gpus", b"_num_gpus"]) -> typing.Literal["num_gpus"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_num_gpus", b"_num_gpus"]) -> typing_extensions.Literal["num_gpus"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_request_timeout", b"_request_timeout"]) -> typing.Literal["request_timeout"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_request_timeout", b"_request_timeout"]) -> typing_extensions.Literal["request_timeout"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_scheduler", b"_scheduler"]) -> typing.Literal["scheduler"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_scheduler", b"_scheduler"]) -> typing_extensions.Literal["scheduler"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_scheduler_options", b"_scheduler_options"]) -> typing.Literal["scheduler_options"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_scheduler_options", b"_scheduler_options"]) -> typing_extensions.Literal["scheduler_options"] | None: ... global___MachineRequirements = MachineRequirements -@typing.final +@typing_extensions.final class RegisterApplicationRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -448,35 +435,30 @@ class RegisterApplicationRequest(google.protobuf.message.Message): METADATA_FIELD_NUMBER: builtins.int DEPLOYMENT_STRATEGY_FIELD_NUMBER: builtins.int SCALE_FIELD_NUMBER: builtins.int - application_name: builtins.str - """Name of the application""" - auth_mode: global___ApplicationAuthMode.ValueType - """If application has alias: auth mode to use""" - max_concurrency: builtins.int - """Max concurrency in gateway""" - deployment_strategy: global___DeploymentStrategy.ValueType - """Deployment strategy""" - scale: builtins.bool @property def environments(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[server_pb2.EnvironmentDefinition]: """Environment definitions.""" - @property def machine_requirements(self) -> global___MachineRequirements: """Machine requirements""" - @property def function(self) -> common_pb2.SerializedObject: """Function to run.""" - @property def setup_func(self) -> common_pb2.SerializedObject: """Optional setup function to pass as the first argument to the function.""" - + application_name: builtins.str + """Name of the application""" + auth_mode: global___ApplicationAuthMode.ValueType + """If application has alias: auth mode to use""" + max_concurrency: builtins.int + """Max concurrency in gateway""" @property def metadata(self) -> google.protobuf.struct_pb2.Struct: """metadata to store with the application""" - + deployment_strategy: global___DeploymentStrategy.ValueType + """Deployment strategy""" + scale: builtins.bool def __init__( self, *, @@ -491,28 +473,28 @@ class RegisterApplicationRequest(google.protobuf.message.Message): deployment_strategy: global___DeploymentStrategy.ValueType | None = ..., scale: builtins.bool | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_application_name", b"_application_name", "_auth_mode", b"_auth_mode", "_deployment_strategy", b"_deployment_strategy", "_machine_requirements", b"_machine_requirements", "_max_concurrency", b"_max_concurrency", "_metadata", b"_metadata", "_scale", b"_scale", "_setup_func", b"_setup_func", "application_name", b"application_name", "auth_mode", b"auth_mode", "deployment_strategy", b"deployment_strategy", "environments", b"environments", "function", b"function", "machine_requirements", b"machine_requirements", "max_concurrency", b"max_concurrency", "metadata", b"metadata", "scale", b"scale", "setup_func", b"setup_func"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_application_name", b"_application_name"]) -> typing.Literal["application_name"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_application_name", b"_application_name"]) -> typing_extensions.Literal["application_name"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_auth_mode", b"_auth_mode"]) -> typing.Literal["auth_mode"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_auth_mode", b"_auth_mode"]) -> typing_extensions.Literal["auth_mode"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_deployment_strategy", b"_deployment_strategy"]) -> typing.Literal["deployment_strategy"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_deployment_strategy", b"_deployment_strategy"]) -> typing_extensions.Literal["deployment_strategy"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_machine_requirements", b"_machine_requirements"]) -> typing.Literal["machine_requirements"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_machine_requirements", b"_machine_requirements"]) -> typing_extensions.Literal["machine_requirements"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_concurrency", b"_max_concurrency"]) -> typing.Literal["max_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_concurrency", b"_max_concurrency"]) -> typing_extensions.Literal["max_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_metadata", b"_metadata"]) -> typing.Literal["metadata"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_metadata", b"_metadata"]) -> typing_extensions.Literal["metadata"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_scale", b"_scale"]) -> typing.Literal["scale"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_scale", b"_scale"]) -> typing_extensions.Literal["scale"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_setup_func", b"_setup_func"]) -> typing.Literal["setup_func"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_setup_func", b"_setup_func"]) -> typing_extensions.Literal["setup_func"] | None: ... global___RegisterApplicationRequest = RegisterApplicationRequest -@typing.final +@typing_extensions.final class RegisterApplicationResultType(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -523,11 +505,11 @@ class RegisterApplicationResultType(google.protobuf.message.Message): *, application_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["application_id", b"application_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["application_id", b"application_id"]) -> None: ... global___RegisterApplicationResultType = RegisterApplicationResultType -@typing.final +@typing_extensions.final class RegisterApplicationResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -543,13 +525,13 @@ class RegisterApplicationResult(google.protobuf.message.Message): logs: collections.abc.Iterable[common_pb2.Log] | None = ..., result: global___RegisterApplicationResultType | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_result", b"_result", "result", b"result"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_result", b"_result", "logs", b"logs", "result", b"result"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_result", b"_result"]) -> typing.Literal["result"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_result", b"_result", "result", b"result"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_result", b"_result", "logs", b"logs", "result", b"result"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_result", b"_result"]) -> typing_extensions.Literal["result"] | None: ... global___RegisterApplicationResult = RegisterApplicationResult -@typing.final +@typing_extensions.final class UpdateApplicationRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -572,20 +554,20 @@ class UpdateApplicationRequest(google.protobuf.message.Message): max_concurrency: builtins.int | None = ..., min_concurrency: builtins.int | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "application_name", b"application_name", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_keep_alive", b"_keep_alive", "_max_concurrency", b"_max_concurrency", "_max_multiplexing", b"_max_multiplexing", "_min_concurrency", b"_min_concurrency", "application_name", b"application_name", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_keep_alive", b"_keep_alive"]) -> typing.Literal["keep_alive"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_keep_alive", b"_keep_alive"]) -> typing_extensions.Literal["keep_alive"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_concurrency", b"_max_concurrency"]) -> typing.Literal["max_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_concurrency", b"_max_concurrency"]) -> typing_extensions.Literal["max_concurrency"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing.Literal["max_multiplexing"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_max_multiplexing", b"_max_multiplexing"]) -> typing_extensions.Literal["max_multiplexing"] | None: ... @typing.overload - def WhichOneof(self, oneof_group: typing.Literal["_min_concurrency", b"_min_concurrency"]) -> typing.Literal["min_concurrency"] | None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_min_concurrency", b"_min_concurrency"]) -> typing_extensions.Literal["min_concurrency"] | None: ... global___UpdateApplicationRequest = UpdateApplicationRequest -@typing.final +@typing_extensions.final class UpdateApplicationResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -597,12 +579,12 @@ class UpdateApplicationResult(google.protobuf.message.Message): *, alias_info: global___AliasInfo | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["alias_info", b"alias_info"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["alias_info", b"alias_info"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["alias_info", b"alias_info"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["alias_info", b"alias_info"]) -> None: ... global___UpdateApplicationResult = UpdateApplicationResult -@typing.final +@typing_extensions.final class ListApplicationsRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -614,7 +596,7 @@ class ListApplicationsRequest(google.protobuf.message.Message): global___ListApplicationsRequest = ListApplicationsRequest -@typing.final +@typing_extensions.final class ApplicationInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -640,11 +622,11 @@ class ApplicationInfo(google.protobuf.message.Message): active_runners: builtins.int = ..., min_concurrency: builtins.int = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["active_runners", b"active_runners", "application_id", b"application_id", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["active_runners", b"active_runners", "application_id", b"application_id", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency"]) -> None: ... global___ApplicationInfo = ApplicationInfo -@typing.final +@typing_extensions.final class ListApplicationsResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -656,11 +638,11 @@ class ListApplicationsResult(google.protobuf.message.Message): *, applications: collections.abc.Iterable[global___ApplicationInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["applications", b"applications"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["applications", b"applications"]) -> None: ... global___ListApplicationsResult = ListApplicationsResult -@typing.final +@typing_extensions.final class DeleteApplicationRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -671,11 +653,11 @@ class DeleteApplicationRequest(google.protobuf.message.Message): *, application_id: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["application_id", b"application_id"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["application_id", b"application_id"]) -> None: ... global___DeleteApplicationRequest = DeleteApplicationRequest -@typing.final +@typing_extensions.final class DeleteApplicationResult(google.protobuf.message.Message): """Empty. For future use.""" @@ -687,7 +669,7 @@ class DeleteApplicationResult(google.protobuf.message.Message): global___DeleteApplicationResult = DeleteApplicationResult -@typing.final +@typing_extensions.final class SetAliasRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -704,11 +686,11 @@ class SetAliasRequest(google.protobuf.message.Message): revision: builtins.str = ..., auth_mode: global___ApplicationAuthMode.ValueType = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias", "auth_mode", b"auth_mode", "revision", b"revision"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias", "auth_mode", b"auth_mode", "revision", b"revision"]) -> None: ... global___SetAliasRequest = SetAliasRequest -@typing.final +@typing_extensions.final class SetAliasResult(google.protobuf.message.Message): """Empty. For future use.""" @@ -720,7 +702,7 @@ class SetAliasResult(google.protobuf.message.Message): global___SetAliasResult = SetAliasResult -@typing.final +@typing_extensions.final class DeleteAliasRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -731,11 +713,11 @@ class DeleteAliasRequest(google.protobuf.message.Message): *, alias: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias"]) -> None: ... global___DeleteAliasRequest = DeleteAliasRequest -@typing.final +@typing_extensions.final class DeleteAliasResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -746,11 +728,11 @@ class DeleteAliasResult(google.protobuf.message.Message): *, revision: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["revision", b"revision"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["revision", b"revision"]) -> None: ... global___DeleteAliasResult = DeleteAliasResult -@typing.final +@typing_extensions.final class ListAliasesRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -762,7 +744,7 @@ class ListAliasesRequest(google.protobuf.message.Message): global___ListAliasesRequest = ListAliasesRequest -@typing.final +@typing_extensions.final class ListAliasesResult(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -774,11 +756,11 @@ class ListAliasesResult(google.protobuf.message.Message): *, aliases: collections.abc.Iterable[global___AliasInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["aliases", b"aliases"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["aliases", b"aliases"]) -> None: ... global___ListAliasesResult = ListAliasesResult -@typing.final +@typing_extensions.final class AliasInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -810,11 +792,11 @@ class AliasInfo(google.protobuf.message.Message): active_runners: builtins.int = ..., min_concurrency: builtins.int = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["active_runners", b"active_runners", "alias", b"alias", "auth_mode", b"auth_mode", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "revision", b"revision"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["active_runners", b"active_runners", "alias", b"alias", "auth_mode", b"auth_mode", "keep_alive", b"keep_alive", "max_concurrency", b"max_concurrency", "max_multiplexing", b"max_multiplexing", "min_concurrency", b"min_concurrency", "revision", b"revision"]) -> None: ... global___AliasInfo = AliasInfo -@typing.final +@typing_extensions.final class SetSecretRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -828,13 +810,13 @@ class SetSecretRequest(google.protobuf.message.Message): name: builtins.str = ..., value: builtins.str | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_value", b"_value", "value", b"value"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_value", b"_value", "name", b"name", "value", b"value"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_value", b"_value"]) -> typing.Literal["value"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_value", b"_value", "value", b"value"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_value", b"_value", "name", b"name", "value", b"value"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_value", b"_value"]) -> typing_extensions.Literal["value"] | None: ... global___SetSecretRequest = SetSecretRequest -@typing.final +@typing_extensions.final class SetSecretResponse(google.protobuf.message.Message): """Empty. For future use.""" @@ -846,7 +828,7 @@ class SetSecretResponse(google.protobuf.message.Message): global___SetSecretResponse = SetSecretResponse -@typing.final +@typing_extensions.final class ListSecretsRequest(google.protobuf.message.Message): """Empty. For future use.""" @@ -858,7 +840,7 @@ class ListSecretsRequest(google.protobuf.message.Message): global___ListSecretsRequest = ListSecretsRequest -@typing.final +@typing_extensions.final class Secret(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -868,20 +850,19 @@ class Secret(google.protobuf.message.Message): @property def created_time(self) -> google.protobuf.timestamp_pb2.Timestamp: """Could also include the value/scope of the secret in the future.""" - def __init__( self, *, name: builtins.str = ..., created_time: google.protobuf.timestamp_pb2.Timestamp | None = ..., ) -> None: ... - def HasField(self, field_name: typing.Literal["_created_time", b"_created_time", "created_time", b"created_time"]) -> builtins.bool: ... - def ClearField(self, field_name: typing.Literal["_created_time", b"_created_time", "created_time", b"created_time", "name", b"name"]) -> None: ... - def WhichOneof(self, oneof_group: typing.Literal["_created_time", b"_created_time"]) -> typing.Literal["created_time"] | None: ... + def HasField(self, field_name: typing_extensions.Literal["_created_time", b"_created_time", "created_time", b"created_time"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_created_time", b"_created_time", "created_time", b"created_time", "name", b"name"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_created_time", b"_created_time"]) -> typing_extensions.Literal["created_time"] | None: ... global___Secret = Secret -@typing.final +@typing_extensions.final class ListSecretsResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -893,11 +874,11 @@ class ListSecretsResponse(google.protobuf.message.Message): *, secrets: collections.abc.Iterable[global___Secret] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["secrets", b"secrets"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["secrets", b"secrets"]) -> None: ... global___ListSecretsResponse = ListSecretsResponse -@typing.final +@typing_extensions.final class ListAliasRunnersRequest(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -908,11 +889,11 @@ class ListAliasRunnersRequest(google.protobuf.message.Message): *, alias: builtins.str = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["alias", b"alias"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["alias", b"alias"]) -> None: ... global___ListAliasRunnersRequest = ListAliasRunnersRequest -@typing.final +@typing_extensions.final class ListAliasRunnersResponse(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -924,11 +905,11 @@ class ListAliasRunnersResponse(google.protobuf.message.Message): *, runners: collections.abc.Iterable[global___RunnerInfo] | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["runners", b"runners"]) -> None: ... + def ClearField(self, field_name: typing_extensions.Literal["runners", b"runners"]) -> None: ... global___ListAliasRunnersResponse = ListAliasRunnersResponse -@typing.final +@typing_extensions.final class RunnerInfo(google.protobuf.message.Message): DESCRIPTOR: google.protobuf.descriptor.Descriptor @@ -945,9 +926,11 @@ class RunnerInfo(google.protobuf.message.Message): *, runner_id: builtins.str = ..., in_flight_requests: builtins.int = ..., - expiration_countdown: builtins.int = ..., + expiration_countdown: builtins.int | None = ..., uptime: builtins.float = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["expiration_countdown", b"expiration_countdown", "in_flight_requests", b"in_flight_requests", "runner_id", b"runner_id", "uptime", b"uptime"]) -> None: ... + def HasField(self, field_name: typing_extensions.Literal["_expiration_countdown", b"_expiration_countdown", "expiration_countdown", b"expiration_countdown"]) -> builtins.bool: ... + def ClearField(self, field_name: typing_extensions.Literal["_expiration_countdown", b"_expiration_countdown", "expiration_countdown", b"expiration_countdown", "in_flight_requests", b"in_flight_requests", "runner_id", b"runner_id", "uptime", b"uptime"]) -> None: ... + def WhichOneof(self, oneof_group: typing_extensions.Literal["_expiration_countdown", b"_expiration_countdown"]) -> typing_extensions.Literal["expiration_countdown"] | None: ... global___RunnerInfo = RunnerInfo