Implement Standalone Nexus Operations

pyproject.toml

@@ -236,7 +236,7 @@ exclude = [
 ]
 
 [tool.ruff]
-target-version = "py39"
+target-version = "py310"
 
 [build-system]
 requires = ["maturin>=1.0,<2.0"]

temporalio/api/command/v1/message_pb2.pyi

@@ -332,6 +332,7 @@ class RequestCancelExternalWorkflowExecutionCommandAttributes(
     CHILD_WORKFLOW_ONLY_FIELD_NUMBER: builtins.int
     REASON_FIELD_NUMBER: builtins.int
     namespace: builtins.str
+    """Deprecated. Cross-namespace operations are disabled by default as of server 1.30.1."""
     workflow_id: builtins.str
     run_id: builtins.str
     control: builtins.str
@@ -386,6 +387,7 @@ class SignalExternalWorkflowExecutionCommandAttributes(google.protobuf.message.M
     CHILD_WORKFLOW_ONLY_FIELD_NUMBER: builtins.int
     HEADER_FIELD_NUMBER: builtins.int
     namespace: builtins.str
+    """Deprecated. Cross-namespace operations are disabled by default as of server 1.30.1."""
     @property
     def execution(self) -> temporalio.api.common.v1.message_pb2.WorkflowExecution: ...
     signal_name: builtins.str
@@ -757,6 +759,7 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
     INHERIT_BUILD_ID_FIELD_NUMBER: builtins.int
     PRIORITY_FIELD_NUMBER: builtins.int
     namespace: builtins.str
+    """Deprecated. Cross-namespace operations are disabled by default as of server 1.30.1."""
     workflow_id: builtins.str
     @property
     def workflow_type(self) -> temporalio.api.common.v1.message_pb2.WorkflowType: ...

temporalio/api/common/v1/__init__.py

@@ -9,6 +9,7 @@
     MeteringMetadata,
     Payload,
     Payloads,
+    Principal,
     Priority,
     ResetOptions,
     RetryPolicy,
@@ -31,6 +32,7 @@
     "MeteringMetadata",
     "Payload",
     "Payloads",
+    "Principal",
     "Priority",
     "ResetOptions",
     "RetryPolicy",

temporalio/api/common/v1/message_pb2.pyi

@@ -883,23 +883,59 @@ class Link(google.protobuf.message.Message):
             self, field_name: typing_extensions.Literal["job_id", b"job_id"]
         ) -> None: ...
 
+    class NexusOperation(google.protobuf.message.Message):
+        """A link to a standalone Nexus operation."""
+
+        DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+        NAMESPACE_FIELD_NUMBER: builtins.int
+        OPERATION_ID_FIELD_NUMBER: builtins.int
+        RUN_ID_FIELD_NUMBER: builtins.int
+        namespace: builtins.str
+        operation_id: builtins.str
+        run_id: builtins.str
+        def __init__(
+            self,
+            *,
+            namespace: builtins.str = ...,
+            operation_id: builtins.str = ...,
+            run_id: builtins.str = ...,
+        ) -> None: ...
+        def ClearField(
+            self,
+            field_name: typing_extensions.Literal[
+                "namespace",
+                b"namespace",
+                "operation_id",
+                b"operation_id",
+                "run_id",
+                b"run_id",
+            ],
+        ) -> None: ...
+
     WORKFLOW_EVENT_FIELD_NUMBER: builtins.int
     BATCH_JOB_FIELD_NUMBER: builtins.int
+    NEXUS_OPERATION_FIELD_NUMBER: builtins.int
     @property
     def workflow_event(self) -> global___Link.WorkflowEvent: ...
     @property
     def batch_job(self) -> global___Link.BatchJob: ...
+    @property
+    def nexus_operation(self) -> global___Link.NexusOperation: ...
     def __init__(
         self,
         *,
         workflow_event: global___Link.WorkflowEvent | None = ...,
         batch_job: global___Link.BatchJob | None = ...,
+        nexus_operation: global___Link.NexusOperation | None = ...,
     ) -> None: ...
     def HasField(
         self,
         field_name: typing_extensions.Literal[
             "batch_job",
             b"batch_job",
+            "nexus_operation",
+            b"nexus_operation",
             "variant",
             b"variant",
             "workflow_event",
@@ -911,6 +947,8 @@ class Link(google.protobuf.message.Message):
         field_name: typing_extensions.Literal[
             "batch_job",
             b"batch_job",
+            "nexus_operation",
+            b"nexus_operation",
             "variant",
             b"variant",
             "workflow_event",
@@ -919,10 +957,38 @@ class Link(google.protobuf.message.Message):
     ) -> None: ...
     def WhichOneof(
         self, oneof_group: typing_extensions.Literal["variant", b"variant"]
-    ) -> typing_extensions.Literal["workflow_event", "batch_job"] | None: ...
+    ) -> (
+        typing_extensions.Literal["workflow_event", "batch_job", "nexus_operation"]
+        | None
+    ): ...
 
 global___Link = Link
 
+class Principal(google.protobuf.message.Message):
+    """Principal is an authenticated caller identity computed by the server from trusted
+    authentication context.
+    """
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    TYPE_FIELD_NUMBER: builtins.int
+    NAME_FIELD_NUMBER: builtins.int
+    type: builtins.str
+    """Low-cardinality category of the principal (e.g., "jwt", "users")."""
+    name: builtins.str
+    """Identifier within that category (e.g., sub JWT claim, email address)."""
+    def __init__(
+        self,
+        *,
+        type: builtins.str = ...,
+        name: builtins.str = ...,
+    ) -> None: ...
+    def ClearField(
+        self, field_name: typing_extensions.Literal["name", b"name", "type", b"type"]
+    ) -> None: ...
+
+global___Principal = Principal
+
 class Priority(google.protobuf.message.Message):
     """Priority contains metadata that controls relative ordering of task processing
     when tasks are backed up in a queue. Initially, Priority will be used in

temporalio/api/compute/v1/__init__.py

@@ -0,0 +1,15 @@
+from .config_pb2 import (
+    ComputeConfig,
+    ComputeConfigScalingGroup,
+    ComputeConfigScalingGroupUpdate,
+)
+from .provider_pb2 import ComputeProvider
+from .scaler_pb2 import ComputeScaler
+
+__all__ = [
+    "ComputeConfig",
+    "ComputeConfigScalingGroup",
+    "ComputeConfigScalingGroupUpdate",
+    "ComputeProvider",
+    "ComputeScaler",
+]