Update core and update Rust dependencies (#337)

Author: cretz

scripts/gen_protos.py

@@ -23,6 +23,7 @@
     for v in proto_dir.glob("**/*.proto")
     if not str(v).startswith(str(testsrv_proto_dir / "dependencies"))
     and not "health" in str(v)
+    and not "google" in str(v)
 ]
 proto_paths.extend(test_proto_dir.glob("**/*.proto"))
 proto_paths.extend(additional_proto_dir.glob("**/*.proto"))

temporalio/api/batch/v1/__init__.py

@@ -2,6 +2,7 @@
     BatchOperationCancellation,
     BatchOperationDeletion,
     BatchOperationInfo,
+    BatchOperationReset,
     BatchOperationSignal,
     BatchOperationTermination,
 )
@@ -10,6 +11,7 @@
     "BatchOperationCancellation",
     "BatchOperationDeletion",
     "BatchOperationInfo",
+    "BatchOperationReset",
     "BatchOperationSignal",
     "BatchOperationTermination",
 ]

temporalio/api/batch/v1/message_pb2.py

@@ -30,6 +30,7 @@ import google.protobuf.timestamp_pb2
 import sys
 import temporalio.api.common.v1.message_pb2
 import temporalio.api.enums.v1.batch_operation_pb2
+import temporalio.api.enums.v1.reset_pb2
 
 if sys.version_info >= (3, 8):
     import typing as typing_extensions
@@ -211,3 +212,40 @@ class BatchOperationDeletion(google.protobuf.message.Message):
     ) -> None: ...
 
 global___BatchOperationDeletion = BatchOperationDeletion
+
+class BatchOperationReset(google.protobuf.message.Message):
+    """BatchOperationReset sends reset requests to batch workflows.
+    Keep the parameter in sync with temporalio.api.workflowservice.v1.ResetWorkflowExecutionRequest.
+    """
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    RESET_TYPE_FIELD_NUMBER: builtins.int
+    RESET_REAPPLY_TYPE_FIELD_NUMBER: builtins.int
+    IDENTITY_FIELD_NUMBER: builtins.int
+    reset_type: temporalio.api.enums.v1.reset_pb2.ResetType.ValueType
+    """Reset type."""
+    reset_reapply_type: temporalio.api.enums.v1.reset_pb2.ResetReapplyType.ValueType
+    """History event reapply options."""
+    identity: builtins.str
+    """The identity of the worker/client."""
+    def __init__(
+        self,
+        *,
+        reset_type: temporalio.api.enums.v1.reset_pb2.ResetType.ValueType = ...,
+        reset_reapply_type: temporalio.api.enums.v1.reset_pb2.ResetReapplyType.ValueType = ...,
+        identity: builtins.str = ...,
+    ) -> None: ...
+    def ClearField(
+        self,
+        field_name: typing_extensions.Literal[
+            "identity",
+            b"identity",
+            "reset_reapply_type",
+            b"reset_reapply_type",
+            "reset_type",
+            b"reset_type",
+        ],
+    ) -> None: ...
+
+global___BatchOperationReset = BatchOperationReset

temporalio/api/batch/v1/message_pb2.pyi

@@ -57,6 +57,7 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
     HEARTBEAT_TIMEOUT_FIELD_NUMBER: builtins.int
     RETRY_POLICY_FIELD_NUMBER: builtins.int
     REQUEST_EAGER_EXECUTION_FIELD_NUMBER: builtins.int
+    USE_COMPATIBLE_VERSION_FIELD_NUMBER: builtins.int
     activity_id: builtins.str
     @property
     def activity_type(self) -> temporalio.api.common.v1.message_pb2.ActivityType: ...
@@ -110,6 +111,11 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
     """Request to start the activity directly bypassing matching service and worker polling
     The slot for executing the activity should be reserved when setting this field to true.
     """
+    use_compatible_version: builtins.bool
+    """If this is set, the workflow executing this command wishes to start the activity using
+    a version compatible with the version that this workflow most recently ran on, if such
+    behavior is possible.
+    """
     def __init__(
         self,
         *,
@@ -124,6 +130,7 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
         heartbeat_timeout: google.protobuf.duration_pb2.Duration | None = ...,
         retry_policy: temporalio.api.common.v1.message_pb2.RetryPolicy | None = ...,
         request_eager_execution: builtins.bool = ...,
+        use_compatible_version: builtins.bool = ...,
     ) -> None: ...
     def HasField(
         self,
@@ -173,6 +180,8 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
             b"start_to_close_timeout",
             "task_queue",
             b"task_queue",
+            "use_compatible_version",
+            b"use_compatible_version",
         ],
     ) -> None: ...
 
@@ -591,6 +600,7 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
     HEADER_FIELD_NUMBER: builtins.int
     MEMO_FIELD_NUMBER: builtins.int
     SEARCH_ATTRIBUTES_FIELD_NUMBER: builtins.int
+    USE_COMPATIBLE_VERSION_FIELD_NUMBER: builtins.int
     @property
     def workflow_type(self) -> temporalio.api.common.v1.message_pb2.WorkflowType: ...
     @property
@@ -626,6 +636,10 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
     def search_attributes(
         self,
     ) -> temporalio.api.common.v1.message_pb2.SearchAttributes: ...
+    use_compatible_version: builtins.bool
+    """If this is set, the workflow executing this command wishes to continue as new using a version
+    compatible with the version that this workflow most recently ran on.
+    """
     def __init__(
         self,
         *,
@@ -645,6 +659,7 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
         memo: temporalio.api.common.v1.message_pb2.Memo | None = ...,
         search_attributes: temporalio.api.common.v1.message_pb2.SearchAttributes
         | None = ...,
+        use_compatible_version: builtins.bool = ...,
     ) -> None: ...
     def HasField(
         self,
@@ -700,6 +715,8 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
             b"search_attributes",
             "task_queue",
             b"task_queue",
+            "use_compatible_version",
+            b"use_compatible_version",
             "workflow_run_timeout",
             b"workflow_run_timeout",
             "workflow_task_timeout",
@@ -732,6 +749,7 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
     HEADER_FIELD_NUMBER: builtins.int
     MEMO_FIELD_NUMBER: builtins.int
     SEARCH_ATTRIBUTES_FIELD_NUMBER: builtins.int
+    USE_COMPATIBLE_VERSION_FIELD_NUMBER: builtins.int
     namespace: builtins.str
     workflow_id: builtins.str
     @property
@@ -766,6 +784,11 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
     def search_attributes(
         self,
     ) -> temporalio.api.common.v1.message_pb2.SearchAttributes: ...
+    use_compatible_version: builtins.bool
+    """If this is set, the workflow executing this command wishes to start the child workflow using
+    a version compatible with the version that this workflow most recently ran on, if such
+    behavior is possible.
+    """
     def __init__(
         self,
         *,
@@ -786,6 +809,7 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
         memo: temporalio.api.common.v1.message_pb2.Memo | None = ...,
         search_attributes: temporalio.api.common.v1.message_pb2.SearchAttributes
         | None = ...,
+        use_compatible_version: builtins.bool = ...,
     ) -> None: ...
     def HasField(
         self,
@@ -835,6 +859,8 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
             b"search_attributes",
             "task_queue",
             b"task_queue",
+            "use_compatible_version",
+            b"use_compatible_version",
             "workflow_execution_timeout",
             b"workflow_execution_timeout",
             "workflow_id",