Regen protos

Author: Sushisource

temporalio/api/common/v1/__init__.py

@@ -4,6 +4,7 @@
     Callback,
     DataBlob,
     Header,
+    Link,
     Memo,
     MeteringMetadata,
     Payload,
@@ -23,6 +24,7 @@
     "DataBlob",
     "GrpcStatus",
     "Header",
+    "Link",
     "Memo",
     "MeteringMetadata",
     "Payload",

temporalio/api/common/v1/message_pb2.py

@@ -35,6 +35,7 @@ import google.protobuf.internal.containers
 import google.protobuf.message
 
 import temporalio.api.enums.v1.common_pb2
+import temporalio.api.enums.v1.event_type_pb2
 import temporalio.api.enums.v1.reset_pb2
 
 if sys.version_info >= (3, 8):
@@ -658,24 +659,186 @@ class Callback(google.protobuf.message.Message):
             field_name: typing_extensions.Literal["header", b"header", "url", b"url"],
         ) -> None: ...
 
+    class Internal(google.protobuf.message.Message):
+        """Callbacks to be delivered internally within the system.
+        This variant is not settable in the API and will be rejected by the service with an INVALID_ARGUMENT error.
+        The only reason that this is exposed is because callbacks are replicated across clusters via the
+        WorkflowExecutionStarted event, which is defined in the public API.
+        """
+
+        DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+        DATA_FIELD_NUMBER: builtins.int
+        data: builtins.bytes
+        """Opaque internal data."""
+        def __init__(
+            self,
+            *,
+            data: builtins.bytes = ...,
+        ) -> None: ...
+        def ClearField(
+            self, field_name: typing_extensions.Literal["data", b"data"]
+        ) -> None: ...
+
     NEXUS_FIELD_NUMBER: builtins.int
+    INTERNAL_FIELD_NUMBER: builtins.int
     @property
     def nexus(self) -> global___Callback.Nexus: ...
+    @property
+    def internal(self) -> global___Callback.Internal: ...
     def __init__(
         self,
         *,
         nexus: global___Callback.Nexus | None = ...,
+        internal: global___Callback.Internal | None = ...,
     ) -> None: ...
     def HasField(
         self,
-        field_name: typing_extensions.Literal["nexus", b"nexus", "variant", b"variant"],
+        field_name: typing_extensions.Literal[
+            "internal", b"internal", "nexus", b"nexus", "variant", b"variant"
+        ],
     ) -> builtins.bool: ...
     def ClearField(
         self,
-        field_name: typing_extensions.Literal["nexus", b"nexus", "variant", b"variant"],
+        field_name: typing_extensions.Literal[
+            "internal", b"internal", "nexus", b"nexus", "variant", b"variant"
+        ],
     ) -> None: ...
     def WhichOneof(
         self, oneof_group: typing_extensions.Literal["variant", b"variant"]
-    ) -> typing_extensions.Literal["nexus"] | None: ...
+    ) -> typing_extensions.Literal["nexus", "internal"] | None: ...
 
 global___Callback = Callback
+
+class Link(google.protobuf.message.Message):
+    """Link can be associated with history events. It might contain information about an external entity
+    related to the history event. For example, workflow A makes a Nexus call that starts workflow B:
+    in this case, a history event in workflow A could contain a Link to the workflow started event in
+    workflow B, and vice-versa.
+    """
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    class WorkflowEvent(google.protobuf.message.Message):
+        DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+        class EventReference(google.protobuf.message.Message):
+            DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+            EVENT_ID_FIELD_NUMBER: builtins.int
+            EVENT_TYPE_FIELD_NUMBER: builtins.int
+            event_id: builtins.int
+            event_type: temporalio.api.enums.v1.event_type_pb2.EventType.ValueType
+            def __init__(
+                self,
+                *,
+                event_id: builtins.int = ...,
+                event_type: temporalio.api.enums.v1.event_type_pb2.EventType.ValueType = ...,
+            ) -> None: ...
+            def ClearField(
+                self,
+                field_name: typing_extensions.Literal[
+                    "event_id", b"event_id", "event_type", b"event_type"
+                ],
+            ) -> None: ...
+
+        NAMESPACE_FIELD_NUMBER: builtins.int
+        WORKFLOW_ID_FIELD_NUMBER: builtins.int
+        RUN_ID_FIELD_NUMBER: builtins.int
+        EVENT_REF_FIELD_NUMBER: builtins.int
+        namespace: builtins.str
+        workflow_id: builtins.str
+        run_id: builtins.str
+        @property
+        def event_ref(self) -> global___Link.WorkflowEvent.EventReference: ...
+        def __init__(
+            self,
+            *,
+            namespace: builtins.str = ...,
+            workflow_id: builtins.str = ...,
+            run_id: builtins.str = ...,
+            event_ref: global___Link.WorkflowEvent.EventReference | None = ...,
+        ) -> None: ...
+        def HasField(
+            self,
+            field_name: typing_extensions.Literal[
+                "event_ref", b"event_ref", "reference", b"reference"
+            ],
+        ) -> builtins.bool: ...
+        def ClearField(
+            self,
+            field_name: typing_extensions.Literal[
+                "event_ref",
+                b"event_ref",
+                "namespace",
+                b"namespace",
+                "reference",
+                b"reference",
+                "run_id",
+                b"run_id",
+                "workflow_id",
+                b"workflow_id",
+            ],
+        ) -> None: ...
+        def WhichOneof(
+            self, oneof_group: typing_extensions.Literal["reference", b"reference"]
+        ) -> typing_extensions.Literal["event_ref"] | None: ...
+
+    class BatchJob(google.protobuf.message.Message):
+        """A link to a built-in batch job.
+        Batch jobs can be used to perform operations on a set of workflows (e.g. terminate, signal, cancel, etc).
+        This link can be put on workflow history events generated by actions taken by a batch job.
+        """
+
+        DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+        JOB_ID_FIELD_NUMBER: builtins.int
+        job_id: builtins.str
+        def __init__(
+            self,
+            *,
+            job_id: builtins.str = ...,
+        ) -> None: ...
+        def ClearField(
+            self, field_name: typing_extensions.Literal["job_id", b"job_id"]
+        ) -> None: ...
+
+    WORKFLOW_EVENT_FIELD_NUMBER: builtins.int
+    BATCH_JOB_FIELD_NUMBER: builtins.int
+    @property
+    def workflow_event(self) -> global___Link.WorkflowEvent: ...
+    @property
+    def batch_job(self) -> global___Link.BatchJob: ...
+    def __init__(
+        self,
+        *,
+        workflow_event: global___Link.WorkflowEvent | None = ...,
+        batch_job: global___Link.BatchJob | None = ...,
+    ) -> None: ...
+    def HasField(
+        self,
+        field_name: typing_extensions.Literal[
+            "batch_job",
+            b"batch_job",
+            "variant",
+            b"variant",
+            "workflow_event",
+            b"workflow_event",
+        ],
+    ) -> builtins.bool: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal[
+            "batch_job",
+            b"batch_job",
+            "variant",
+            b"variant",
+            "workflow_event",
+            b"workflow_event",
+        ],
+    ) -> None: ...
+    def WhichOneof(
+        self, oneof_group: typing_extensions.Literal["variant", b"variant"]
+    ) -> typing_extensions.Literal["workflow_event", "batch_job"] | None: ...
+
+global___Link = Link

temporalio/api/common/v1/message_pb2.pyi

@@ -188,10 +188,15 @@ class _EventTypeEnumTypeWrapper(
     """Temporal Server has successfully Signaled the targeted Workflow"""
     EVENT_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES: _EventType.ValueType  # 40
     """Workflow search attributes should be updated and synchronized with the visibility store"""
+    EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED: _EventType.ValueType  # 47
+    """An update was admitted. Note that not all admitted updates result in this
+    event. See UpdateAdmittedEventOrigin for situations in which this event
+    is created.
+    """
     EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ACCEPTED: _EventType.ValueType  # 41
-    """An update was accepted (i.e. validated)"""
+    """An update was accepted (i.e. passed validation, perhaps because no validator was defined)"""
     EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_REJECTED: _EventType.ValueType  # 42
-    """An update was rejected (i.e. failed validation)"""
+    """This event is never written to history."""
     EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_COMPLETED: _EventType.ValueType  # 43
     """An update completed"""
     EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED_EXTERNALLY: _EventType.ValueType  # 44
@@ -206,11 +211,6 @@ class _EventTypeEnumTypeWrapper(
     """
     EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED: _EventType.ValueType  # 46
     """Workflow properties modified by user workflow code"""
-    EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED: _EventType.ValueType  # 47
-    """An update was admitted. Note that not all admitted updates result in this
-    event. See UpdateAdmittedEventOrigin for situations in which this event
-    is created.
-    """
     EVENT_TYPE_NEXUS_OPERATION_SCHEDULED: _EventType.ValueType  # 48
     """A Nexus operation was scheduled using a ScheduleNexusOperation command."""
     EVENT_TYPE_NEXUS_OPERATION_STARTED: _EventType.ValueType  # 49
@@ -368,10 +368,15 @@ EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED: EventType.ValueType  # 39
 """Temporal Server has successfully Signaled the targeted Workflow"""
 EVENT_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES: EventType.ValueType  # 40
 """Workflow search attributes should be updated and synchronized with the visibility store"""
+EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED: EventType.ValueType  # 47
+"""An update was admitted. Note that not all admitted updates result in this
+event. See UpdateAdmittedEventOrigin for situations in which this event
+is created.
+"""
 EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ACCEPTED: EventType.ValueType  # 41
-"""An update was accepted (i.e. validated)"""
+"""An update was accepted (i.e. passed validation, perhaps because no validator was defined)"""
 EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_REJECTED: EventType.ValueType  # 42
-"""An update was rejected (i.e. failed validation)"""
+"""This event is never written to history."""
 EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_COMPLETED: EventType.ValueType  # 43
 """An update completed"""
 EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED_EXTERNALLY: EventType.ValueType  # 44
@@ -386,11 +391,6 @@ maintain determinism when using the command-based approach.
 """
 EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED: EventType.ValueType  # 46
 """Workflow properties modified by user workflow code"""
-EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED: EventType.ValueType  # 47
-"""An update was admitted. Note that not all admitted updates result in this
-event. See UpdateAdmittedEventOrigin for situations in which this event
-is created.
-"""
 EVENT_TYPE_NEXUS_OPERATION_SCHEDULED: EventType.ValueType  # 48
 """A Nexus operation was scheduled using a ScheduleNexusOperation command."""
 EVENT_TYPE_NEXUS_OPERATION_STARTED: EventType.ValueType  # 49