Run formatter. Fix linter. pnpm install to fix nexus-rpc version

Author: VegetarianOrc

packages/core-bridge/src/client.rs

@@ -264,13 +264,19 @@ async fn client_invoke_workflow_service(
         "CountActivityExecutions" => rpc_call!(connection, call, count_activity_executions),
         "CountSchedules" => rpc_call!(connection, call, count_schedules),
         "CountWorkflowExecutions" => rpc_call!(connection, call, count_workflow_executions),
-        "CountNexusOperationExecutions" => rpc_call!(connection, call, count_nexus_operation_executions),
+        "CountNexusOperationExecutions" => {
+            rpc_call!(connection, call, count_nexus_operation_executions)
+        }
         "CreateSchedule" => rpc_call!(connection, call, create_schedule),
         "CreateWorkerDeployment" => rpc_call!(connection, call, create_worker_deployment),
-        "CreateWorkerDeploymentVersion" => rpc_call!(connection, call, create_worker_deployment_version),
+        "CreateWorkerDeploymentVersion" => {
+            rpc_call!(connection, call, create_worker_deployment_version)
+        }
         "CreateWorkflowRule" => rpc_call!(connection, call, create_workflow_rule),
         "DeleteActivityExecution" => rpc_call!(connection, call, delete_activity_execution),
-        "DeleteNexusOperationExecution" => rpc_call!(connection, call, delete_nexus_operation_execution),
+        "DeleteNexusOperationExecution" => {
+            rpc_call!(connection, call, delete_nexus_operation_execution)
+        }
         "DeleteSchedule" => rpc_call!(connection, call, delete_schedule),
         "DeleteWorkerDeployment" => rpc_call!(connection, call, delete_worker_deployment),
         "DeleteWorkerDeploymentVersion" => {
@@ -281,7 +287,9 @@ async fn client_invoke_workflow_service(
         "DescribeBatchOperation" => rpc_call!(connection, call, describe_batch_operation),
         "DescribeActivityExecution" => rpc_call!(connection, call, describe_activity_execution),
         "DescribeDeployment" => rpc_call!(connection, call, describe_deployment),
-        "DescribeNexusOperationExecution" => rpc_call!(connection, call, describe_nexus_operation_execution),
+        "DescribeNexusOperationExecution" => {
+            rpc_call!(connection, call, describe_nexus_operation_execution)
+        }
         "DescribeWorker" => rpc_call!(connection, call, describe_worker),
         "DeprecateNamespace" => rpc_call!(connection, call, deprecate_namespace),
         "DescribeNamespace" => rpc_call!(connection, call, describe_namespace),
@@ -321,7 +329,9 @@ async fn client_invoke_workflow_service(
         }
         "ListDeployments" => rpc_call!(connection, call, list_deployments),
         "ListNamespaces" => rpc_call!(connection, call, list_namespaces),
-        "ListNexusOperationExecutions" => rpc_call!(connection, call, list_nexus_operation_executions),
+        "ListNexusOperationExecutions" => {
+            rpc_call!(connection, call, list_nexus_operation_executions)
+        }
         "ListOpenWorkflowExecutions" => rpc_call!(connection, call, list_open_workflow_executions),
         "ListScheduleMatchingTimes" => rpc_call!(connection, call, list_schedule_matching_times),
         "ListSchedules" => rpc_call!(connection, call, list_schedules),
@@ -335,7 +345,9 @@ async fn client_invoke_workflow_service(
         "PauseWorkflowExecution" => rpc_call!(connection, call, pause_workflow_execution),
         "PollActivityExecution" => rpc_call!(connection, call, poll_activity_execution),
         "PollActivityTaskQueue" => rpc_call!(connection, call, poll_activity_task_queue),
-        "PollNexusOperationExecution" => rpc_call!(connection, call, poll_nexus_operation_execution),
+        "PollNexusOperationExecution" => {
+            rpc_call!(connection, call, poll_nexus_operation_execution)
+        }
         "PollNexusTaskQueue" => rpc_call!(connection, call, poll_nexus_task_queue),
         "PollWorkflowExecutionUpdate" => {
             rpc_call!(connection, call, poll_workflow_execution_update)
@@ -402,10 +414,14 @@ async fn client_invoke_workflow_service(
         "StartActivityExecution" => rpc_call!(connection, call, start_activity_execution),
         "StartWorkflowExecution" => rpc_call!(connection, call, start_workflow_execution),
         "StartBatchOperation" => rpc_call!(connection, call, start_batch_operation),
-        "StartNexusOperationExecution" => rpc_call!(connection, call, start_nexus_operation_execution),
+        "StartNexusOperationExecution" => {
+            rpc_call!(connection, call, start_nexus_operation_execution)
+        }
         "StopBatchOperation" => rpc_call!(connection, call, stop_batch_operation),
         "TerminateActivityExecution" => rpc_call!(connection, call, terminate_activity_execution),
-        "TerminateNexusOperationExecution" => rpc_call!(connection, call, terminate_nexus_operation_execution),
+        "TerminateNexusOperationExecution" => {
+            rpc_call!(connection, call, terminate_nexus_operation_execution)
+        }
         "TerminateWorkflowExecution" => rpc_call!(connection, call, terminate_workflow_execution),
         "TriggerWorkflowRule" => rpc_call!(connection, call, trigger_workflow_rule),
         "UnpauseActivity" => rpc_call!(connection, call, unpause_activity),
@@ -414,7 +430,11 @@ async fn client_invoke_workflow_service(
         "UpdateNamespace" => rpc_call!(connection, call, update_namespace),
         "UpdateSchedule" => rpc_call!(connection, call, update_schedule),
         "UpdateWorkerConfig" => rpc_call!(connection, call, update_worker_config),
-        "UpdateWorkerDeploymentVersionComputeConfig" => rpc_call!(connection, call, update_worker_deployment_version_compute_config),
+        "UpdateWorkerDeploymentVersionComputeConfig" => rpc_call!(
+            connection,
+            call,
+            update_worker_deployment_version_compute_config
+        ),
         "UpdateWorkerDeploymentVersionMetadata" => {
             rpc_call!(connection, call, update_worker_deployment_version_metadata)
         }
@@ -430,7 +450,11 @@ async fn client_invoke_workflow_service(
             rpc_call!(connection, call, update_worker_versioning_rules)
         }
         "ValidateWorkerDeploymentVersionComputeConfig" => {
-            rpc_call!(connection, call, validate_worker_deployment_version_compute_config)
+            rpc_call!(
+                connection,
+                call,
+                validate_worker_deployment_version_compute_config
+            )
         }
         _ => Err(BridgeError::TypeError {
             field: None,

packages/test/src/test-nexus-standalone.ts

@@ -250,7 +250,7 @@ test('count and list operations', async (t) => {
     // Visibility has update delay, repeating query until the activity count is as expected
     await waitUntil(async () => {
       const result = await client.nexus.count(`Endpoint="${endpointName}"`);
-      return result.count == 3;
+      return result.count === 3;
     }, 10000);
 
     const seen = new Set<string>();