Update upstream_api to latest

crates/client/src/grpc.rs

@@ -1582,6 +1582,114 @@ proxier! {
             r.extensions_mut().insert(labels);
         }
     );
+    (
+        count_nexus_operation_executions,
+        CountNexusOperationExecutionsRequest,
+        CountNexusOperationExecutionsResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        create_worker_deployment,
+        CreateWorkerDeploymentRequest,
+        CreateWorkerDeploymentResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        create_worker_deployment_version,
+        CreateWorkerDeploymentVersionRequest,
+        CreateWorkerDeploymentVersionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        delete_nexus_operation_execution,
+        DeleteNexusOperationExecutionRequest,
+        DeleteNexusOperationExecutionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        describe_nexus_operation_execution,
+        DescribeNexusOperationExecutionRequest,
+        DescribeNexusOperationExecutionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        list_nexus_operation_executions,
+        ListNexusOperationExecutionsRequest,
+        ListNexusOperationExecutionsResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        poll_nexus_operation_execution,
+        PollNexusOperationExecutionRequest,
+        PollNexusOperationExecutionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        request_cancel_nexus_operation_execution,
+        RequestCancelNexusOperationExecutionRequest,
+        RequestCancelNexusOperationExecutionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        start_nexus_operation_execution,
+        StartNexusOperationExecutionRequest,
+        StartNexusOperationExecutionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        terminate_nexus_operation_execution,
+        TerminateNexusOperationExecutionRequest,
+        TerminateNexusOperationExecutionResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        update_worker_deployment_version_compute_config,
+        UpdateWorkerDeploymentVersionComputeConfigRequest,
+        UpdateWorkerDeploymentVersionComputeConfigResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
+    (
+        validate_worker_deployment_version_compute_config,
+        ValidateWorkerDeploymentVersionComputeConfigRequest,
+        ValidateWorkerDeploymentVersionComputeConfigResponse,
+        |r| {
+            let labels = namespaced_request!(r);
+            r.extensions_mut().insert(labels);
+        }
+    );
 }
 
 proxier! {

crates/common/build.rs

@@ -30,8 +30,10 @@ const SERDE_DERIVE_PREFIXES: &[&str] = &[
     ".grpc",
     ".temporal.api.activity",
     ".temporal.api.batch",
+    ".temporal.api.callback",
     ".temporal.api.cloud",
     ".temporal.api.command",
+    ".temporal.api.compute",
     ".temporal.api.deployment",
     ".temporal.api.filter",
     ".temporal.api.history",

crates/common/protos/api_upstream/.github/PULL_REQUEST_TEMPLATE.md

@@ -1,5 +1,3 @@
-_**READ BEFORE MERGING:** All PRs require approval by both Server AND SDK teams before merging! This is why the number of required approvals is "2" and not "1"--two reviewers from the same team is NOT sufficient. If your PR is not approved by someone in BOTH teams, it may be summarily reverted._
-
 <!-- Describe what has changed in this PR -->
 **What changed?**
 

crates/common/protos/api_upstream/.github/workflows/trigger-api-go-update.yml

@@ -56,7 +56,7 @@ jobs:
           esac
 
           gh workflow run update-proto.yml -R https://github.com/temporalio/api-go \
-            -r master \
+            -r "${BRANCH}" \
             -f branch="${BRANCH}" \
             -f commit_author="${COMMIT_AUTHOR}" \
             -f commit_author_email="${COMMIT_AUTHOR_EMAIL}" \

crates/common/protos/api_upstream/.gitignore

@@ -2,4 +2,6 @@
 /.gen
 /.vscode
 /.stamp
-*~
+*~
+*.swp
+*.swo

crates/common/protos/api_upstream/nexus-rpc/temporal-proto-models-nexusrpc.yaml

@@ -0,0 +1,32 @@
+# yaml-language-server: $schema=https://raw.githubusercontent.com/nexus-rpc/nexus-rpc-gen/main/schemas/nexus-rpc-gen.json
+#
+# Nexus service definition for server-to-worker communication.
+# See request_response.proto for message definitions.
+#
+# Task queue format: /temporal-sys/worker-commands/{namespace}/{worker_grouping_key}
+
+nexusrpc: 1.0.0
+
+services:
+  temporal.api.nexusservices.workerservice.v1.WorkerService:
+    description: >
+      Internal Nexus service for server-to-worker communication.
+      Used by the Temporal server to send commands to workers.
+    operations:
+      ExecuteCommands:
+        description: Executes worker commands sent by the server.
+        input:
+          $goRef: "go.temporal.io/api/nexusservices/workerservice/v1.ExecuteCommandsRequest"
+          $javaRef: "io.temporal.api.nexusservices.workerservice.v1.ExecuteCommandsRequest"
+          $pythonRef: "temporalio.api.nexusservices.workerservice.v1.ExecuteCommandsRequest"
+          $typescriptRef: "@temporalio/api/nexusservices/workerservice/v1.ExecuteCommandsRequest"
+          $dotnetRef: "Temporalio.Api.Nexusservices.Workerservice.V1.ExecuteCommandsRequest"
+          $rubyRef: "Temporalio::Api::Nexusservices::Workerservice::V1::ExecuteCommandsRequest"
+        output:
+          $goRef: "go.temporal.io/api/nexusservices/workerservice/v1.ExecuteCommandsResponse"
+          $javaRef: "io.temporal.api.nexusservices.workerservice.v1.ExecuteCommandsResponse"
+          $pythonRef: "temporalio.api.nexusservices.workerservice.v1.ExecuteCommandsResponse"
+          $typescriptRef: "@temporalio/api/nexusservices/workerservice/v1.ExecuteCommandsResponse"
+          $dotnetRef: "Temporalio.Api.Nexusservices.Workerservice.V1.ExecuteCommandsResponse"
+          $rubyRef: "Temporalio::Api::Nexusservices::Workerservice::V1::ExecuteCommandsResponse"
+