Skip to content

Commit fb8ab55

Browse files
author
Sophia Tevosyan
committed
first commit
1 parent 27b9a6e commit fb8ab55

File tree

2 files changed

+18
-1
lines changed

2 files changed

+18
-1
lines changed

src/Grpc/orchestrator_service.proto

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -276,6 +276,7 @@ message CreateSubOrchestrationAction {
276276
google.protobuf.StringValue version = 3;
277277
google.protobuf.StringValue input = 4;
278278
TraceContext parentTraceContext = 5;
279+
map<string, string> tags = 6;
279280
}
280281

281282
message CreateTimerAction {
@@ -356,6 +357,13 @@ message OrchestratorResponse {
356357

357358
// Whether or not a history is required to complete the original OrchestratorRequest and none was provided.
358359
bool requiresHistory = 7;
360+
361+
// True if this is a partial (chunked) completion. The backend must keep the work item open until the final chunk (isPartial=false).
362+
bool isPartial = 8;
363+
364+
// Zero-based position of the current chunk within a chunked completion sequence.
365+
// This field is omitted for non-chunked completions.
366+
google.protobuf.Int32Value chunkIndex = 9;
359367
}
360368

361369
message CreateInstanceRequest {

src/Shared/Grpc/ProtoUtils.cs

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -373,7 +373,16 @@ internal static P.OrchestratorResponse ConstructOrchestratorResponse(
373373
Name = subOrchestrationAction.Name,
374374
Version = subOrchestrationAction.Version,
375375
ParentTraceContext = CreateTraceContext(),
376-
};
376+
};
377+
378+
if (subOrchestrationAction.Tags != null)
379+
{
380+
foreach (KeyValuePair<string, string> tag in subOrchestrationAction.Tags)
381+
{
382+
protoAction.CreateSubOrchestration.Tags[tag.Key] = tag.Value;
383+
}
384+
}
385+
377386
break;
378387
case OrchestratorActionType.CreateTimer:
379388
var createTimerAction = (CreateTimerOrchestratorAction)action;

0 commit comments

Comments
 (0)