Skip to content

Commit 0604373

Browse files
author
Sophia Tevosyan
committed
added proto changes from main branch
1 parent 5972863 commit 0604373

File tree

2 files changed

+24
-13
lines changed

2 files changed

+24
-13
lines changed

src/Grpc/orchestrator_service.proto

Lines changed: 22 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ message EntityOperationCalledEvent {
193193
}
194194

195195
message EntityLockRequestedEvent {
196-
string criticalSectionId = 1;
196+
string criticalSectionId = 1;
197197
repeated string lockSet = 2;
198198
int32 position = 3;
199199
google.protobuf.StringValue parentInstanceId = 4; // used only within messages, null in histories
@@ -218,7 +218,7 @@ message EntityUnlockSentEvent {
218218
message EntityLockGrantedEvent {
219219
string criticalSectionId = 1;
220220
}
221-
221+
222222
message HistoryEvent {
223223
int32 eventId = 1;
224224
google.protobuf.Timestamp timestamp = 2;
@@ -245,8 +245,8 @@ message HistoryEvent {
245245
ExecutionResumedEvent executionResumed = 22;
246246
EntityOperationSignaledEvent entityOperationSignaled = 23;
247247
EntityOperationCalledEvent entityOperationCalled = 24;
248-
EntityOperationCompletedEvent entityOperationCompleted = 25;
249-
EntityOperationFailedEvent entityOperationFailed = 26;
248+
EntityOperationCompletedEvent entityOperationCompleted = 25;
249+
EntityOperationFailedEvent entityOperationFailed = 26;
250250
EntityLockRequestedEvent entityLockRequested = 27;
251251
EntityLockGrantedEvent entityLockGranted = 28;
252252
EntityUnlockSentEvent entityUnlockSent = 29;
@@ -258,13 +258,15 @@ message ScheduleTaskAction {
258258
google.protobuf.StringValue version = 2;
259259
google.protobuf.StringValue input = 3;
260260
map<string, string> tags = 4;
261+
TraceContext parentTraceContext = 5;
261262
}
262263

263264
message CreateSubOrchestrationAction {
264265
string instanceId = 1;
265266
string name = 2;
266267
google.protobuf.StringValue version = 3;
267268
google.protobuf.StringValue input = 4;
269+
TraceContext parentTraceContext = 5;
268270
}
269271

270272
message CreateTimerAction {
@@ -314,6 +316,11 @@ message OrchestratorAction {
314316
}
315317
}
316318

319+
message OrchestrationTraceContext {
320+
google.protobuf.StringValue spanID = 1;
321+
google.protobuf.Timestamp spanStartTime = 2;
322+
}
323+
317324
message OrchestratorRequest {
318325
string instanceId = 1;
319326
google.protobuf.StringValue executionId = 2;
@@ -322,6 +329,8 @@ message OrchestratorRequest {
322329
OrchestratorEntityParameters entityParameters = 5;
323330
bool requiresHistoryStreaming = 6;
324331
map<string, google.protobuf.Value> properties = 7;
332+
333+
OrchestrationTraceContext orchestrationTraceContext = 8;
325334
}
326335

327336
message OrchestratorResponse {
@@ -333,8 +342,10 @@ message OrchestratorResponse {
333342
// The number of work item events that were processed by the orchestrator.
334343
// This field is optional. If not set, the service should assume that the orchestrator processed all events.
335344
google.protobuf.Int32Value numEventsProcessed = 5;
345+
OrchestrationTraceContext orchestrationTraceContext = 6;
346+
336347
// Whether or not a history is required to complete the original OrchestratorRequest and none was provided.
337-
bool requiresHistory = 6;
348+
bool requiresHistory = 7;
338349
}
339350

340351
message CreateInstanceRequest {
@@ -500,7 +511,7 @@ message SignalEntityRequest {
500511
}
501512

502513
message SignalEntityResponse {
503-
// no payload
514+
// no payload
504515
}
505516

506517
message GetEntityRequest {
@@ -675,16 +686,16 @@ service TaskHubSidecarService {
675686

676687
// Waits for an orchestration instance to reach a running or completion state.
677688
rpc WaitForInstanceStart(GetInstanceRequest) returns (GetInstanceResponse);
678-
689+
679690
// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
680691
rpc WaitForInstanceCompletion(GetInstanceRequest) returns (GetInstanceResponse);
681692

682693
// Raises an event to a running orchestration instance.
683694
rpc RaiseEvent(RaiseEventRequest) returns (RaiseEventResponse);
684-
695+
685696
// Terminates a running orchestration instance.
686697
rpc TerminateInstance(TerminateRequest) returns (TerminateResponse);
687-
698+
688699
// Suspends a running orchestration instance.
689700
rpc SuspendInstance(SuspendRequest) returns (SuspendResponse);
690701

@@ -766,7 +777,7 @@ message CompleteTaskResponse {
766777
}
767778

768779
message HealthPing {
769-
// No payload
780+
// No payload
770781
}
771782

772783
message StreamInstanceHistoryRequest {
@@ -779,4 +790,4 @@ message StreamInstanceHistoryRequest {
779790

780791
message HistoryChunk {
781792
repeated HistoryEvent events = 1;
782-
}
793+
}

src/Grpc/versions.txt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
# The following files were downloaded from branch stevosyan/extended-sessions-for-orchestrations-isolated at 2025-08-21 02:06:15 UTC
2-
https://raw.githubusercontent.com/microsoft/durabletask-protobuf/930a06ef7df4f3156fdaa619e8e4d6439d43fcb5/protos/orchestrator_service.proto
1+
# The following files were downloaded from branch stevosyan/extended-sessions-for-orchestrations-isolated at 2025-08-21 02:14:04 UTC
2+
https://raw.githubusercontent.com/microsoft/durabletask-protobuf/42cc3e416e9b227ed0a68c7dfd504ab5aed84e26/protos/orchestrator_service.proto

0 commit comments

Comments
 (0)