Skip to content

Commit f973bb2

Browse files
committed
Updated protos again
1 parent ee0df92 commit f973bb2

File tree

3 files changed

+15
-4
lines changed

3 files changed

+15
-4
lines changed

src/Grpc/orchestrator_service.proto

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -670,7 +670,18 @@ message GetWorkItemsRequest {
670670
int32 maxConcurrentOrchestrationWorkItems = 1;
671671
int32 maxConcurrentActivityWorkItems = 2;
672672
int32 maxConcurrentEntityWorkItems = 3;
673-
bool supportsHistoryStreaming = 4;
673+
674+
repeated WorkerCapability capabilities = 10;
675+
}
676+
677+
enum WorkerCapability {
678+
WORKER_CAPABILITY_UNSPECIFIED = 0;
679+
680+
// Indicates that the worker is capable of streaming instance history as a more optimized
681+
// alternative to receiving the full history embedded in the orchestrator work-item.
682+
// When set, the service may return work items without any history events as an optimization.
683+
// It is strongly recommended that all SDKs support this capability.
684+
WORKER_CAPABILITY_HISTORY_STREAMING = 1;
674685
}
675686

676687
message WorkItem {

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 cgillum/history-streaming at 2025-01-27 00:38:40 UTC
2-
https://raw.githubusercontent.com/microsoft/durabletask-protobuf/64417b16a3e32487ff4bf026db015e9f94fd5615/protos/orchestrator_service.proto
1+
# The following files were downloaded from branch cgillum/history-streaming at 2025-01-29 20:42:19 UTC
2+
https://raw.githubusercontent.com/microsoft/durabletask-protobuf/c93e046fe7d4d47785dd5314b3863eddd0fd6b48/protos/orchestrator_service.proto

src/Worker/Grpc/GrpcDurableTaskWorker.Processor.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ async ValueTask<OrchestrationRuntimeState> BuildRuntimeStateAsync(
170170
workerOptions.Concurrency.MaximumConcurrentOrchestrationWorkItems,
171171
MaxConcurrentEntityWorkItems =
172172
workerOptions.Concurrency.MaximumConcurrentEntityWorkItems,
173-
SupportsHistoryStreaming = true,
173+
Capabilities = { P.WorkerCapability.HistoryStreaming },
174174
},
175175
cancellationToken: cancellation);
176176
}

0 commit comments

Comments
 (0)