Skip to content

Commit 50ecdc7

Browse files
committed
implement missing WorkflowService methods
1 parent c222d63 commit 50ecdc7

1 file changed

Lines changed: 16 additions & 0 deletions

File tree

packages/core-bridge/src/client.rs

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -264,9 +264,13 @@ async fn client_invoke_workflow_service(
264264
"CountActivityExecutions" => rpc_call!(connection, call, count_activity_executions),
265265
"CountSchedules" => rpc_call!(connection, call, count_schedules),
266266
"CountWorkflowExecutions" => rpc_call!(connection, call, count_workflow_executions),
267+
"CountNexusOperationExecutions" => rpc_call!(connection, call, count_nexus_operation_executions),
267268
"CreateSchedule" => rpc_call!(connection, call, create_schedule),
269+
"CreateWorkerDeployment" => rpc_call!(connection, call, create_worker_deployment),
270+
"CreateWorkerDeploymentVersion" => rpc_call!(connection, call, create_worker_deployment_version),
268271
"CreateWorkflowRule" => rpc_call!(connection, call, create_workflow_rule),
269272
"DeleteActivityExecution" => rpc_call!(connection, call, delete_activity_execution),
273+
"DeleteNexusOperationExecution" => rpc_call!(connection, call, delete_nexus_operation_execution),
270274
"DeleteSchedule" => rpc_call!(connection, call, delete_schedule),
271275
"DeleteWorkerDeployment" => rpc_call!(connection, call, delete_worker_deployment),
272276
"DeleteWorkerDeploymentVersion" => {
@@ -277,6 +281,7 @@ async fn client_invoke_workflow_service(
277281
"DescribeBatchOperation" => rpc_call!(connection, call, describe_batch_operation),
278282
"DescribeActivityExecution" => rpc_call!(connection, call, describe_activity_execution),
279283
"DescribeDeployment" => rpc_call!(connection, call, describe_deployment),
284+
"DescribeNexusOperationExecution" => rpc_call!(connection, call, describe_nexus_operation_execution),
280285
"DescribeWorker" => rpc_call!(connection, call, describe_worker),
281286
"DeprecateNamespace" => rpc_call!(connection, call, deprecate_namespace),
282287
"DescribeNamespace" => rpc_call!(connection, call, describe_namespace),
@@ -316,6 +321,7 @@ async fn client_invoke_workflow_service(
316321
}
317322
"ListDeployments" => rpc_call!(connection, call, list_deployments),
318323
"ListNamespaces" => rpc_call!(connection, call, list_namespaces),
324+
"ListNexusOperationExecutions" => rpc_call!(connection, call, list_nexus_operation_executions),
319325
"ListOpenWorkflowExecutions" => rpc_call!(connection, call, list_open_workflow_executions),
320326
"ListScheduleMatchingTimes" => rpc_call!(connection, call, list_schedule_matching_times),
321327
"ListSchedules" => rpc_call!(connection, call, list_schedules),
@@ -329,6 +335,7 @@ async fn client_invoke_workflow_service(
329335
"PauseWorkflowExecution" => rpc_call!(connection, call, pause_workflow_execution),
330336
"PollActivityExecution" => rpc_call!(connection, call, poll_activity_execution),
331337
"PollActivityTaskQueue" => rpc_call!(connection, call, poll_activity_task_queue),
338+
"PollNexusOperationExecution" => rpc_call!(connection, call, poll_nexus_operation_execution),
332339
"PollNexusTaskQueue" => rpc_call!(connection, call, poll_nexus_task_queue),
333340
"PollWorkflowExecutionUpdate" => {
334341
rpc_call!(connection, call, poll_workflow_execution_update)
@@ -346,6 +353,9 @@ async fn client_invoke_workflow_service(
346353
"RequestCancelActivityExecution" => {
347354
rpc_call!(connection, call, request_cancel_activity_execution)
348355
}
356+
"RequestCancelNexusOperationExecution" => {
357+
rpc_call!(connection, call, request_cancel_nexus_operation_execution)
358+
}
349359
"RequestCancelWorkflowExecution" => {
350360
rpc_call!(connection, call, request_cancel_workflow_execution)
351361
}
@@ -392,8 +402,10 @@ async fn client_invoke_workflow_service(
392402
"StartActivityExecution" => rpc_call!(connection, call, start_activity_execution),
393403
"StartWorkflowExecution" => rpc_call!(connection, call, start_workflow_execution),
394404
"StartBatchOperation" => rpc_call!(connection, call, start_batch_operation),
405+
"StartNexusOperationExecution" => rpc_call!(connection, call, start_nexus_operation_execution),
395406
"StopBatchOperation" => rpc_call!(connection, call, stop_batch_operation),
396407
"TerminateActivityExecution" => rpc_call!(connection, call, terminate_activity_execution),
408+
"TerminateNexusOperationExecution" => rpc_call!(connection, call, terminate_nexus_operation_execution),
397409
"TerminateWorkflowExecution" => rpc_call!(connection, call, terminate_workflow_execution),
398410
"TriggerWorkflowRule" => rpc_call!(connection, call, trigger_workflow_rule),
399411
"UnpauseActivity" => rpc_call!(connection, call, unpause_activity),
@@ -402,6 +414,7 @@ async fn client_invoke_workflow_service(
402414
"UpdateNamespace" => rpc_call!(connection, call, update_namespace),
403415
"UpdateSchedule" => rpc_call!(connection, call, update_schedule),
404416
"UpdateWorkerConfig" => rpc_call!(connection, call, update_worker_config),
417+
"UpdateWorkerDeploymentVersionComputeConfig" => rpc_call!(connection, call, update_worker_deployment_version_compute_config),
405418
"UpdateWorkerDeploymentVersionMetadata" => {
406419
rpc_call!(connection, call, update_worker_deployment_version_metadata)
407420
}
@@ -416,6 +429,9 @@ async fn client_invoke_workflow_service(
416429
"UpdateWorkerVersioningRules" => {
417430
rpc_call!(connection, call, update_worker_versioning_rules)
418431
}
432+
"ValidateWorkerDeploymentVersionComputeConfig" => {
433+
rpc_call!(connection, call, validate_worker_deployment_version_compute_config)
434+
}
419435
_ => Err(BridgeError::TypeError {
420436
field: None,
421437
message: format!("Unknown RPC call {}", call.rpc),

0 commit comments

Comments
 (0)