Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions src/Grpc/orchestrator_service.proto
Original file line number Diff line number Diff line change
Expand Up @@ -276,6 +276,7 @@ message CreateSubOrchestrationAction {
google.protobuf.StringValue version = 3;
google.protobuf.StringValue input = 4;
TraceContext parentTraceContext = 5;
map<string, string> tags = 6;
}

message CreateTimerAction {
Expand Down Expand Up @@ -356,6 +357,13 @@ message OrchestratorResponse {

// Whether or not a history is required to complete the original OrchestratorRequest and none was provided.
bool requiresHistory = 7;

// True if this is a partial (chunked) completion. The backend must keep the work item open until the final chunk (isPartial=false).
bool isPartial = 8;

// Zero-based position of the current chunk within a chunked completion sequence.
// This field is omitted for non-chunked completions.
google.protobuf.Int32Value chunkIndex = 9;
Comment thread
sophiatev marked this conversation as resolved.
}

message CreateInstanceRequest {
Expand Down
11 changes: 10 additions & 1 deletion src/Shared/Grpc/ProtoUtils.cs
Original file line number Diff line number Diff line change
Expand Up @@ -373,7 +373,16 @@ internal static P.OrchestratorResponse ConstructOrchestratorResponse(
Name = subOrchestrationAction.Name,
Version = subOrchestrationAction.Version,
ParentTraceContext = CreateTraceContext(),
};
};

if (subOrchestrationAction.Tags != null)
{
foreach (KeyValuePair<string, string> tag in subOrchestrationAction.Tags)
{
protoAction.CreateSubOrchestration.Tags[tag.Key] = tag.Value;
}
}
Comment thread
sophiatev marked this conversation as resolved.

break;
case OrchestratorActionType.CreateTimer:
var createTimerAction = (CreateTimerOrchestratorAction)action;
Expand Down
Loading