@@ -41,7 +41,6 @@ message TaskFailureDetails {
4141 google.protobuf.StringValue stackTrace = 3 ;
4242 TaskFailureDetails innerFailure = 4 ;
4343 bool isNonRetriable = 5 ;
44- map <string , google.protobuf.Value > properties = 6 ;
4544}
4645
4746enum OrchestrationStatus {
@@ -96,7 +95,6 @@ message TaskScheduledEvent {
9695 google.protobuf.StringValue version = 2 ;
9796 google.protobuf.StringValue input = 3 ;
9897 TraceContext parentTraceContext = 4 ;
99- map <string , string > tags = 5 ;
10098}
10199
102100message TaskCompletedEvent {
@@ -194,7 +192,7 @@ message EntityOperationCalledEvent {
194192}
195193
196194message EntityLockRequestedEvent {
197- string criticalSectionId = 1 ;
195+ string criticalSectionId = 1 ;
198196 repeated string lockSet = 2 ;
199197 int32 position = 3 ;
200198 google.protobuf.StringValue parentInstanceId = 4 ; // used only within messages, null in histories
@@ -219,14 +217,7 @@ message EntityUnlockSentEvent {
219217message EntityLockGrantedEvent {
220218 string criticalSectionId = 1 ;
221219}
222-
223- message ExecutionRewoundEvent {
224- google.protobuf.StringValue reason = 1 ;
225- google.protobuf.StringValue parentExecutionId = 2 ; // used only for rewinding suborchestrations, null otherwise
226- google.protobuf.StringValue instanceId = 3 ; // used only for rewinding suborchestrations, null otherwise
227- TraceContext parentTraceContext = 4 ; // used only for rewinding suborchestrations, null otherwise
228- }
229-
220+
230221message HistoryEvent {
231222 int32 eventId = 1 ;
232223 google.protobuf.Timestamp timestamp = 2 ;
@@ -253,29 +244,25 @@ message HistoryEvent {
253244 ExecutionResumedEvent executionResumed = 22 ;
254245 EntityOperationSignaledEvent entityOperationSignaled = 23 ;
255246 EntityOperationCalledEvent entityOperationCalled = 24 ;
256- EntityOperationCompletedEvent entityOperationCompleted = 25 ;
257- EntityOperationFailedEvent entityOperationFailed = 26 ;
247+ EntityOperationCompletedEvent entityOperationCompleted = 25 ;
248+ EntityOperationFailedEvent entityOperationFailed = 26 ;
258249 EntityLockRequestedEvent entityLockRequested = 27 ;
259250 EntityLockGrantedEvent entityLockGranted = 28 ;
260251 EntityUnlockSentEvent entityUnlockSent = 29 ;
261- ExecutionRewoundEvent executionRewound = 30 ;
262252 }
263253}
264254
265255message ScheduleTaskAction {
266256 string name = 1 ;
267257 google.protobuf.StringValue version = 2 ;
268258 google.protobuf.StringValue input = 3 ;
269- map <string , string > tags = 4 ;
270- TraceContext parentTraceContext = 5 ;
271259}
272260
273261message CreateSubOrchestrationAction {
274262 string instanceId = 1 ;
275263 string name = 2 ;
276264 google.protobuf.StringValue version = 3 ;
277265 google.protobuf.StringValue input = 4 ;
278- TraceContext parentTraceContext = 5 ;
279266}
280267
281268message CreateTimerAction {
@@ -295,7 +282,6 @@ message CompleteOrchestrationAction {
295282 google.protobuf.StringValue newVersion = 4 ;
296283 repeated HistoryEvent carryoverEvents = 5 ;
297284 TaskFailureDetails failureDetails = 6 ;
298- map <string , string > tags = 7 ;
299285}
300286
301287message TerminateOrchestrationAction {
@@ -326,11 +312,6 @@ message OrchestratorAction {
326312 }
327313}
328314
329- message OrchestrationTraceContext {
330- google.protobuf.StringValue spanID = 1 ;
331- google.protobuf.Timestamp spanStartTime = 2 ;
332- }
333-
334315message OrchestratorRequest {
335316 string instanceId = 1 ;
336317 google.protobuf.StringValue executionId = 2 ;
@@ -339,8 +320,6 @@ message OrchestratorRequest {
339320 OrchestratorEntityParameters entityParameters = 5 ;
340321 bool requiresHistoryStreaming = 6 ;
341322 map <string , google.protobuf.Value > properties = 7 ;
342-
343- OrchestrationTraceContext orchestrationTraceContext = 8 ;
344323}
345324
346325message OrchestratorResponse {
@@ -352,17 +331,6 @@ message OrchestratorResponse {
352331 // The number of work item events that were processed by the orchestrator.
353332 // This field is optional. If not set, the service should assume that the orchestrator processed all events.
354333 google.protobuf.Int32Value numEventsProcessed = 5 ;
355- OrchestrationTraceContext orchestrationTraceContext = 6 ;
356-
357- // Whether or not a history is required to complete the original OrchestratorRequest and none was provided.
358- bool requiresHistory = 7 ;
359-
360- // True if this is a partial (chunked) completion. The backend must keep the work item open until the final chunk (isPartial=false).
361- bool isPartial = 8 ;
362-
363- // Zero-based position of the current chunk within a chunked completion sequence.
364- // This field is omitted for non-chunked completions.
365- google.protobuf.Int32Value chunkIndex = 9 ;
366334}
367335
368336message CreateInstanceRequest {
@@ -375,7 +343,6 @@ message CreateInstanceRequest {
375343 google.protobuf.StringValue executionId = 7 ;
376344 map <string , string > tags = 8 ;
377345 TraceContext parentTraceContext = 9 ;
378- google.protobuf.Timestamp requestTime = 10 ;
379346}
380347
381348message OrchestrationIdReusePolicy {
@@ -486,7 +453,6 @@ message PurgeInstancesRequest {
486453 oneof request {
487454 string instanceId = 1 ;
488455 PurgeInstanceFilter purgeInstanceFilter = 2 ;
489- InstanceBatch instanceBatch = 4 ;
490456 }
491457 bool recursive = 3 ;
492458}
@@ -502,15 +468,6 @@ message PurgeInstancesResponse {
502468 google.protobuf.BoolValue isComplete = 2 ;
503469}
504470
505- message RestartInstanceRequest {
506- string instanceId = 1 ;
507- bool restartWithNewInstanceId = 2 ;
508- }
509-
510- message RestartInstanceResponse {
511- string instanceId = 1 ;
512- }
513-
514471message CreateTaskHubRequest {
515472 bool recreateIfExists = 1 ;
516473}
@@ -533,12 +490,10 @@ message SignalEntityRequest {
533490 google.protobuf.StringValue input = 3 ;
534491 string requestId = 4 ;
535492 google.protobuf.Timestamp scheduledTime = 5 ;
536- TraceContext parentTraceContext = 6 ;
537- google.protobuf.Timestamp requestTime = 7 ;
538493}
539494
540495message SignalEntityResponse {
541- // no payload
496+ // no payload
542497}
543498
544499message GetEntityRequest {
@@ -620,7 +575,6 @@ message OperationRequest {
620575 string operation = 1 ;
621576 string requestId = 2 ;
622577 google.protobuf.StringValue input = 3 ;
623- TraceContext traceContext = 4 ;
624578}
625579
626580message OperationResult {
@@ -637,14 +591,10 @@ message OperationInfo {
637591
638592message OperationResultSuccess {
639593 google.protobuf.StringValue result = 1 ;
640- google.protobuf.Timestamp startTimeUtc = 2 ;
641- google.protobuf.Timestamp endTimeUtc = 3 ;
642594}
643595
644596message OperationResultFailure {
645597 TaskFailureDetails failureDetails = 1 ;
646- google.protobuf.Timestamp startTimeUtc = 2 ;
647- google.protobuf.Timestamp endTimeUtc = 3 ;
648598}
649599
650600message OperationAction {
@@ -660,8 +610,6 @@ message SendSignalAction {
660610 string name = 2 ;
661611 google.protobuf.StringValue input = 3 ;
662612 google.protobuf.Timestamp scheduledTime = 4 ;
663- google.protobuf.Timestamp requestTime = 5 ;
664- TraceContext parentTraceContext = 6 ;
665613}
666614
667615message StartNewOrchestrationAction {
@@ -670,8 +618,6 @@ message StartNewOrchestrationAction {
670618 google.protobuf.StringValue version = 3 ;
671619 google.protobuf.StringValue input = 4 ;
672620 google.protobuf.Timestamp scheduledTime = 5 ;
673- google.protobuf.Timestamp requestTime = 6 ;
674- TraceContext parentTraceContext = 7 ;
675621}
676622
677623message AbandonActivityTaskRequest {
@@ -698,17 +644,6 @@ message AbandonEntityTaskResponse {
698644 // Empty.
699645}
700646
701- message SkipGracefulOrchestrationTerminationsRequest {
702- InstanceBatch instanceBatch = 1 ;
703- google.protobuf.StringValue reason = 2 ;
704- }
705-
706- message SkipGracefulOrchestrationTerminationsResponse {
707- // Those instances which could not be terminated because they had locked entities at the time of this termination call,
708- // are already in a terminal state (completed, failed, terminated, etc.), are not orchestrations, or do not exist (i.e. have been purged)
709- repeated string unterminatedInstanceIds = 1 ;
710- }
711-
712647service TaskHubSidecarService {
713648 // Sends a hello request to the sidecar service.
714649 rpc Hello (google.protobuf.Empty ) returns (google.protobuf.Empty );
@@ -722,21 +657,18 @@ service TaskHubSidecarService {
722657 // Rewinds an orchestration instance to last known good state and replays from there.
723658 rpc RewindInstance (RewindInstanceRequest ) returns (RewindInstanceResponse );
724659
725- // Restarts an orchestration instance.
726- rpc RestartInstance (RestartInstanceRequest ) returns (RestartInstanceResponse );
727-
728660 // Waits for an orchestration instance to reach a running or completion state.
729661 rpc WaitForInstanceStart (GetInstanceRequest ) returns (GetInstanceResponse );
730-
662+
731663 // Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
732664 rpc WaitForInstanceCompletion (GetInstanceRequest ) returns (GetInstanceResponse );
733665
734666 // Raises an event to a running orchestration instance.
735667 rpc RaiseEvent (RaiseEventRequest ) returns (RaiseEventResponse );
736-
668+
737669 // Terminates a running orchestration instance.
738670 rpc TerminateInstance (TerminateRequest ) returns (TerminateResponse );
739-
671+
740672 // Suspends a running orchestration instance.
741673 rpc SuspendInstance (SuspendRequest ) returns (SuspendResponse );
742674
@@ -782,10 +714,6 @@ service TaskHubSidecarService {
782714
783715 // Abandon an entity work item
784716 rpc AbandonTaskEntityWorkItem (AbandonEntityTaskRequest ) returns (AbandonEntityTaskResponse );
785-
786- // "Skip" graceful termination of orchestrations by immediately changing their status in storage to "terminated".
787- // Note that a maximum of 500 orchestrations can be terminated at a time using this method.
788- rpc SkipGracefulOrchestrationTerminations (SkipGracefulOrchestrationTerminationsRequest ) returns (SkipGracefulOrchestrationTerminationsResponse );
789717}
790718
791719message GetWorkItemsRequest {
@@ -804,16 +732,6 @@ enum WorkerCapability {
804732 // When set, the service may return work items without any history events as an optimization.
805733 // It is strongly recommended that all SDKs support this capability.
806734 WORKER_CAPABILITY_HISTORY_STREAMING = 1 ;
807-
808- // Indicates that the worker supports scheduled tasks.
809- // The service may send schedule-triggered orchestration work items,
810- // and the worker must handle them, including the scheduledTime field.
811- WORKER_CAPABILITY_SCHEDULED_TASKS = 2 ;
812-
813- // Signals that the worker can handle large payloads stored externally (e.g., Blob Storage).
814- // Work items may contain URI references instead of inline data, and the worker must fetch them.
815- // This avoids message size limits and reduces network overhead.
816- WORKER_CAPABILITY_LARGE_PAYLOADS = 3 ;
817735}
818736
819737message WorkItem {
@@ -832,7 +750,7 @@ message CompleteTaskResponse {
832750}
833751
834752message HealthPing {
835- // No payload
753+ // No payload
836754}
837755
838756message StreamInstanceHistoryRequest {
@@ -846,8 +764,3 @@ message StreamInstanceHistoryRequest {
846764message HistoryChunk {
847765 repeated HistoryEvent events = 1 ;
848766}
849-
850- message InstanceBatch {
851- // A maximum of 500 instance IDs can be provided in this list.
852- repeated string instanceIds = 1 ;
853- }
0 commit comments