Skip to content
Merged
2 changes: 2 additions & 0 deletions temporalio/api/batch/v1/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
BatchOperationReset,
BatchOperationSignal,
BatchOperationTermination,
BatchOperationTriggerWorkflowRule,
BatchOperationUnpauseActivities,
BatchOperationUpdateWorkflowExecutionOptions,
)
Expand All @@ -16,6 +17,7 @@
"BatchOperationReset",
"BatchOperationSignal",
"BatchOperationTermination",
"BatchOperationTriggerWorkflowRule",
"BatchOperationUnpauseActivities",
"BatchOperationUpdateWorkflowExecutionOptions",
]
53 changes: 36 additions & 17 deletions temporalio/api/batch/v1/message_pb2.py

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

41 changes: 41 additions & 0 deletions temporalio/api/batch/v1/message_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@ import google.protobuf.timestamp_pb2
import temporalio.api.common.v1.message_pb2
import temporalio.api.enums.v1.batch_operation_pb2
import temporalio.api.enums.v1.reset_pb2
import temporalio.api.rules.v1.message_pb2
import temporalio.api.workflow.v1.message_pb2

if sys.version_info >= (3, 8):
Expand Down Expand Up @@ -392,3 +393,43 @@ class BatchOperationUnpauseActivities(google.protobuf.message.Message):
) -> typing_extensions.Literal["type", "match_all"] | None: ...

global___BatchOperationUnpauseActivities = BatchOperationUnpauseActivities

class BatchOperationTriggerWorkflowRule(google.protobuf.message.Message):
"""BatchOperationTriggerWorkflowRule sends TriggerWorkflowRule requests to batch workflows."""

DESCRIPTOR: google.protobuf.descriptor.Descriptor

IDENTITY_FIELD_NUMBER: builtins.int
ID_FIELD_NUMBER: builtins.int
SPEC_FIELD_NUMBER: builtins.int
identity: builtins.str
"""The identity of the worker/client."""
id: builtins.str
"""ID of existing rule."""
@property
def spec(self) -> temporalio.api.rules.v1.message_pb2.WorkflowRuleSpec:
"""Rule specification to be applied to the workflow without creating a new rule."""
def __init__(
self,
*,
identity: builtins.str = ...,
id: builtins.str = ...,
spec: temporalio.api.rules.v1.message_pb2.WorkflowRuleSpec | None = ...,
) -> None: ...
def HasField(
self,
field_name: typing_extensions.Literal[
"id", b"id", "rule", b"rule", "spec", b"spec"
],
) -> builtins.bool: ...
def ClearField(
self,
field_name: typing_extensions.Literal[
"id", b"id", "identity", b"identity", "rule", b"rule", "spec", b"spec"
],
) -> None: ...
def WhichOneof(
self, oneof_group: typing_extensions.Literal["rule", b"rule"]
) -> typing_extensions.Literal["id", "spec"] | None: ...

global___BatchOperationTriggerWorkflowRule = BatchOperationTriggerWorkflowRule
4 changes: 4 additions & 0 deletions temporalio/api/enums/v1/__init__.py
Original file line number Diff line number Diff line change
@@ -1,12 +1,14 @@
from .batch_operation_pb2 import BatchOperationState, BatchOperationType
from .command_type_pb2 import CommandType
from .common_pb2 import (
ApplicationErrorCategory,
CallbackState,
EncodingType,
IndexedValueType,
NexusOperationCancellationState,
PendingNexusOperationState,
Severity,
WorkflowRuleActionScope,
)
from .deployment_pb2 import (
DeploymentReachability,
Expand Down Expand Up @@ -50,6 +52,7 @@
)

__all__ = [
"ApplicationErrorCategory",
"ArchivalState",
"BatchOperationState",
"BatchOperationType",
Expand Down Expand Up @@ -96,5 +99,6 @@
"WorkflowExecutionStatus",
"WorkflowIdConflictPolicy",
"WorkflowIdReusePolicy",
"WorkflowRuleActionScope",
"WorkflowTaskFailedCause",
]
15 changes: 14 additions & 1 deletion temporalio/api/enums/v1/common_pb2.py

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

Loading
Loading