Skip to content

Commit 6ef144a

Browse files
yuandrewyuandrew
committed
update protos
1 parent 91f92c2 commit 6ef144a

33 files changed

+2377
-1504
lines changed

‎scripts/gen_bridge_client.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ def generate_rust_service_call(service_descriptor: ServiceDescriptor) -> str:
172172
call: RpcCall,
173173
) -> PyResult<Bound<'p, PyAny>> {
174174
self.runtime.assert_same_process("use client")?;
175-
use temporal_client::${descriptor_name};
175+
use temporalio_client::${descriptor_name};
176176
let mut retry_client = self.retry_client.clone();
177177
self.runtime.future_into_py(py, async move {
178178
let bytes = match call.rpc.as_str() {
@@ -182,7 +182,7 @@ def generate_rust_service_call(service_descriptor: ServiceDescriptor) -> str:
182182
"Unknown RPC call {}",
183183
call.rpc
184184
)))
185-
}
185+
}
186186
}?;
187187
Ok(bytes)
188188
})

‎scripts/gen_protos.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111
base_dir = Path(__file__).parent.parent
1212
proto_dir = (
13-
base_dir / "temporalio" / "bridge" / "sdk-core" / "sdk-core-protos" / "protos"
13+
base_dir / "temporalio" / "bridge" / "sdk-core" / "crates" / "common" / "protos"
1414
)
1515
api_proto_dir = proto_dir / "api_upstream"
1616
api_cloud_proto_dir = proto_dir / "api_cloud_upstream"

‎temporalio/api/cloud/account/v1/__init__.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,9 @@
1-
from .message_pb2 import Account, AccountSpec, Metrics, MetricsSpec
1+
from .message_pb2 import Account, AccountSpec, AuditLogSinkSpec, Metrics, MetricsSpec
22

33
__all__ = [
44
"Account",
55
"AccountSpec",
6+
"AuditLogSinkSpec",
67
"Metrics",
78
"MetricsSpec",
89
]

‎temporalio/api/cloud/account/v1/message_pb2.py‎

Lines changed: 26 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎temporalio/api/cloud/account/v1/message_pb2.pyi‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import google.protobuf.descriptor
1010
import google.protobuf.message
1111

1212
import temporalio.api.cloud.resource.v1.message_pb2
13+
import temporalio.api.cloud.sink.v1.message_pb2
1314

1415
if sys.version_info >= (3, 8):
1516
import typing as typing_extensions
@@ -140,3 +141,62 @@ class Account(google.protobuf.message.Message):
140141
) -> None: ...
141142

142143
global___Account = Account
144+
145+
class AuditLogSinkSpec(google.protobuf.message.Message):
146+
"""AuditLogSinkSpec is only used by Audit Log"""
147+
148+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
149+
150+
NAME_FIELD_NUMBER: builtins.int
151+
KINESIS_SINK_FIELD_NUMBER: builtins.int
152+
PUB_SUB_SINK_FIELD_NUMBER: builtins.int
153+
ENABLED_FIELD_NUMBER: builtins.int
154+
name: builtins.str
155+
"""Name of the sink e.g. "audit_log_01" """
156+
@property
157+
def kinesis_sink(self) -> temporalio.api.cloud.sink.v1.message_pb2.KinesisSpec:
158+
"""The KinesisSpec when destination_type is Kinesis"""
159+
@property
160+
def pub_sub_sink(self) -> temporalio.api.cloud.sink.v1.message_pb2.PubSubSpec:
161+
"""The PubSubSpec when destination_type is PubSub"""
162+
enabled: builtins.bool
163+
"""Enabled indicates whether the sink is enabled or not."""
164+
def __init__(
165+
self,
166+
*,
167+
name: builtins.str = ...,
168+
kinesis_sink: temporalio.api.cloud.sink.v1.message_pb2.KinesisSpec | None = ...,
169+
pub_sub_sink: temporalio.api.cloud.sink.v1.message_pb2.PubSubSpec | None = ...,
170+
enabled: builtins.bool = ...,
171+
) -> None: ...
172+
def HasField(
173+
self,
174+
field_name: typing_extensions.Literal[
175+
"kinesis_sink",
176+
b"kinesis_sink",
177+
"pub_sub_sink",
178+
b"pub_sub_sink",
179+
"sink_type",
180+
b"sink_type",
181+
],
182+
) -> builtins.bool: ...
183+
def ClearField(
184+
self,
185+
field_name: typing_extensions.Literal[
186+
"enabled",
187+
b"enabled",
188+
"kinesis_sink",
189+
b"kinesis_sink",
190+
"name",
191+
b"name",
192+
"pub_sub_sink",
193+
b"pub_sub_sink",
194+
"sink_type",
195+
b"sink_type",
196+
],
197+
) -> None: ...
198+
def WhichOneof(
199+
self, oneof_group: typing_extensions.Literal["sink_type", b"sink_type"]
200+
) -> typing_extensions.Literal["kinesis_sink", "pub_sub_sink"] | None: ...
201+
202+
global___AuditLogSinkSpec = AuditLogSinkSpec

‎temporalio/api/cloud/cloudservice/v1/__init__.py‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,8 @@
8787
RemoveUserGroupMemberResponse,
8888
RenameCustomSearchAttributeRequest,
8989
RenameCustomSearchAttributeResponse,
90+
SetServiceAccountNamespaceAccessRequest,
91+
SetServiceAccountNamespaceAccessResponse,
9092
SetUserGroupNamespaceAccessRequest,
9193
SetUserGroupNamespaceAccessResponse,
9294
SetUserNamespaceAccessRequest,
@@ -109,6 +111,8 @@
109111
UpdateUserGroupResponse,
110112
UpdateUserRequest,
111113
UpdateUserResponse,
114+
ValidateAccountAuditLogSinkRequest,
115+
ValidateAccountAuditLogSinkResponse,
112116
ValidateNamespaceExportSinkRequest,
113117
ValidateNamespaceExportSinkResponse,
114118
)
@@ -202,6 +206,8 @@
202206
"RemoveUserGroupMemberResponse",
203207
"RenameCustomSearchAttributeRequest",
204208
"RenameCustomSearchAttributeResponse",
209+
"SetServiceAccountNamespaceAccessRequest",
210+
"SetServiceAccountNamespaceAccessResponse",
205211
"SetUserGroupNamespaceAccessRequest",
206212
"SetUserGroupNamespaceAccessResponse",
207213
"SetUserNamespaceAccessRequest",
@@ -224,6 +230,8 @@
224230
"UpdateUserGroupResponse",
225231
"UpdateUserRequest",
226232
"UpdateUserResponse",
233+
"ValidateAccountAuditLogSinkRequest",
234+
"ValidateAccountAuditLogSinkResponse",
227235
"ValidateNamespaceExportSinkRequest",
228236
"ValidateNamespaceExportSinkResponse",
229237
]

‎temporalio/api/cloud/cloudservice/v1/request_response_pb2.py‎

Lines changed: 127 additions & 63 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎temporalio/api/cloud/cloudservice/v1/request_response_pb2.pyi‎

Lines changed: 113 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -557,7 +557,7 @@ class GetNamespacesRequest(google.protobuf.message.Message):
557557
NAME_FIELD_NUMBER: builtins.int
558558
page_size: builtins.int
559559
"""The requested size of the page to retrieve.
560-
Cannot exceed 1000.
560+
Cannot exceed 1000.
561561
Optional, defaults to 100.
562562
"""
563563
page_token: builtins.str
@@ -2655,6 +2655,88 @@ class UpdateServiceAccountResponse(google.protobuf.message.Message):
26552655

26562656
global___UpdateServiceAccountResponse = UpdateServiceAccountResponse
26572657

2658+
class SetServiceAccountNamespaceAccessRequest(google.protobuf.message.Message):
2659+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
2660+
2661+
SERVICE_ACCOUNT_ID_FIELD_NUMBER: builtins.int
2662+
NAMESPACE_FIELD_NUMBER: builtins.int
2663+
ACCESS_FIELD_NUMBER: builtins.int
2664+
RESOURCE_VERSION_FIELD_NUMBER: builtins.int
2665+
ASYNC_OPERATION_ID_FIELD_NUMBER: builtins.int
2666+
service_account_id: builtins.str
2667+
"""The ID of the service account to update."""
2668+
namespace: builtins.str
2669+
"""The namespace to set permissions for."""
2670+
@property
2671+
def access(self) -> temporalio.api.cloud.identity.v1.message_pb2.NamespaceAccess:
2672+
"""The namespace access to assign the service account."""
2673+
resource_version: builtins.str
2674+
"""The version of the service account for which this update is intended for.
2675+
The latest version can be found in the GetServiceAccount response.
2676+
"""
2677+
async_operation_id: builtins.str
2678+
"""The ID to use for this async operation - optional."""
2679+
def __init__(
2680+
self,
2681+
*,
2682+
service_account_id: builtins.str = ...,
2683+
namespace: builtins.str = ...,
2684+
access: temporalio.api.cloud.identity.v1.message_pb2.NamespaceAccess
2685+
| None = ...,
2686+
resource_version: builtins.str = ...,
2687+
async_operation_id: builtins.str = ...,
2688+
) -> None: ...
2689+
def HasField(
2690+
self, field_name: typing_extensions.Literal["access", b"access"]
2691+
) -> builtins.bool: ...
2692+
def ClearField(
2693+
self,
2694+
field_name: typing_extensions.Literal[
2695+
"access",
2696+
b"access",
2697+
"async_operation_id",
2698+
b"async_operation_id",
2699+
"namespace",
2700+
b"namespace",
2701+
"resource_version",
2702+
b"resource_version",
2703+
"service_account_id",
2704+
b"service_account_id",
2705+
],
2706+
) -> None: ...
2707+
2708+
global___SetServiceAccountNamespaceAccessRequest = (
2709+
SetServiceAccountNamespaceAccessRequest
2710+
)
2711+
2712+
class SetServiceAccountNamespaceAccessResponse(google.protobuf.message.Message):
2713+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
2714+
2715+
ASYNC_OPERATION_FIELD_NUMBER: builtins.int
2716+
@property
2717+
def async_operation(
2718+
self,
2719+
) -> temporalio.api.cloud.operation.v1.message_pb2.AsyncOperation:
2720+
"""The async operation."""
2721+
def __init__(
2722+
self,
2723+
*,
2724+
async_operation: temporalio.api.cloud.operation.v1.message_pb2.AsyncOperation
2725+
| None = ...,
2726+
) -> None: ...
2727+
def HasField(
2728+
self,
2729+
field_name: typing_extensions.Literal["async_operation", b"async_operation"],
2730+
) -> builtins.bool: ...
2731+
def ClearField(
2732+
self,
2733+
field_name: typing_extensions.Literal["async_operation", b"async_operation"],
2734+
) -> None: ...
2735+
2736+
global___SetServiceAccountNamespaceAccessResponse = (
2737+
SetServiceAccountNamespaceAccessResponse
2738+
)
2739+
26582740
class DeleteServiceAccountRequest(google.protobuf.message.Message):
26592741
DESCRIPTOR: google.protobuf.descriptor.Descriptor
26602742

@@ -3605,3 +3687,33 @@ class DeleteConnectivityRuleResponse(google.protobuf.message.Message):
36053687
) -> None: ...
36063688

36073689
global___DeleteConnectivityRuleResponse = DeleteConnectivityRuleResponse
3690+
3691+
class ValidateAccountAuditLogSinkRequest(google.protobuf.message.Message):
3692+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
3693+
3694+
SPEC_FIELD_NUMBER: builtins.int
3695+
@property
3696+
def spec(self) -> temporalio.api.cloud.account.v1.message_pb2.AuditLogSinkSpec:
3697+
"""The audit log sink spec that will be validated"""
3698+
def __init__(
3699+
self,
3700+
*,
3701+
spec: temporalio.api.cloud.account.v1.message_pb2.AuditLogSinkSpec | None = ...,
3702+
) -> None: ...
3703+
def HasField(
3704+
self, field_name: typing_extensions.Literal["spec", b"spec"]
3705+
) -> builtins.bool: ...
3706+
def ClearField(
3707+
self, field_name: typing_extensions.Literal["spec", b"spec"]
3708+
) -> None: ...
3709+
3710+
global___ValidateAccountAuditLogSinkRequest = ValidateAccountAuditLogSinkRequest
3711+
3712+
class ValidateAccountAuditLogSinkResponse(google.protobuf.message.Message):
3713+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
3714+
3715+
def __init__(
3716+
self,
3717+
) -> None: ...
3718+
3719+
global___ValidateAccountAuditLogSinkResponse = ValidateAccountAuditLogSinkResponse

0 commit comments

Comments
 (0)