diff --git a/proto/api b/proto/api index 6a2313a1..a7daaa64 160000 --- a/proto/api +++ b/proto/api @@ -1 +1 @@ -Subproject commit 6a2313a18130c9f2e967655a8039768297a5d67a +Subproject commit a7daaa6471e98de8f4d501ca8af694484e1a8932 diff --git a/systemnexus/workflowservice/v1/workflow-service.wit b/systemnexus/workflowservice/v1/workflow-service.wit index fa0aa9aa..5b847e54 100644 --- a/systemnexus/workflowservice/v1/workflow-service.wit +++ b/systemnexus/workflowservice/v1/workflow-service.wit @@ -173,6 +173,7 @@ interface workflow-service { start-time: option, /// @nexus.omit workflow-target: placeholder, + idle: option, } /// @nexus.proto "temporal.api.workflowservice.v1.AttachStreamCallbackResponse" @@ -235,4 +236,23 @@ interface workflow-service { use nexus:temporal-types/model@1.0.0.{ failure, }; + /// @nexus.proto "temporal.api.workflowservice.v1.WaitStreamCallbackRequest" + record wait-stream-callback-request { + /// @nexus.source python="workflow_namespace()" typescript="workflowNamespace()" go="workflow.GetInfo(ctx).Namespace" dotnet="TemporalWorkflowContext.WorkflowNamespace()" + /// @nexus.doc "Namespace of the stream." + namespace: string, + stream-ref: option, + request-id: string, + after-counter: option, + /// @nexus.omit + identity: placeholder, + } + + /// @nexus.proto "temporal.api.workflowservice.v1.WaitStreamCallbackResponse" + record wait-stream-callback-response { + } + + wait-stream-callback: func( + request: wait-stream-callback-request, + ) -> wait-stream-callback-response; } diff --git a/workflowservice/v1/workflowservicenexus/service_nexus.pb.go b/workflowservice/v1/workflowservicenexus/service_nexus.pb.go index 3ca7d2fd..6e9ea9ae 100644 --- a/workflowservice/v1/workflowservicenexus/service_nexus.pb.go +++ b/workflowservice/v1/workflowservicenexus/service_nexus.pb.go @@ -12,11 +12,13 @@ var TemporalAPIWorkflowserviceV1WorkflowService = struct { SignalWithStartWorkflowExecution nexus.OperationReference[workflowservicev1.SignalWithStartWorkflowExecutionRequest, workflowservicev1.SignalWithStartWorkflowExecutionResponse] AttachStreamCallback nexus.OperationReference[workflowservicev1.AttachStreamCallbackRequest, workflowservicev1.AttachStreamCallbackResponse] DetachStreamCallback nexus.OperationReference[workflowservicev1.DetachStreamCallbackRequest, workflowservicev1.DetachStreamCallbackResponse] + WaitStreamCallback nexus.OperationReference[workflowservicev1.WaitStreamCallbackRequest, workflowservicev1.WaitStreamCallbackResponse] NotifyStream nexus.OperationReference[workflowservicev1.NotifyStreamRequest, workflowservicev1.NotifyStreamResponse] }{ ServiceName: "temporal.api.workflowservice.v1.WorkflowService", SignalWithStartWorkflowExecution: nexus.NewOperationReference[workflowservicev1.SignalWithStartWorkflowExecutionRequest, workflowservicev1.SignalWithStartWorkflowExecutionResponse]("SignalWithStartWorkflowExecution"), AttachStreamCallback: nexus.NewOperationReference[workflowservicev1.AttachStreamCallbackRequest, workflowservicev1.AttachStreamCallbackResponse]("AttachStreamCallback"), DetachStreamCallback: nexus.NewOperationReference[workflowservicev1.DetachStreamCallbackRequest, workflowservicev1.DetachStreamCallbackResponse]("DetachStreamCallback"), + WaitStreamCallback: nexus.NewOperationReference[workflowservicev1.WaitStreamCallbackRequest, workflowservicev1.WaitStreamCallbackResponse]("WaitStreamCallback"), NotifyStream: nexus.NewOperationReference[workflowservicev1.NotifyStreamRequest, workflowservicev1.NotifyStreamResponse]("NotifyStream"), }