update protos

Signed-off-by: Cassandra Coyle <[email protected]>

Author: cicoyle

CONTRIBUTING.md

@@ -2,4 +2,16 @@ Build & test:
 
 ```shell
 ./gradlew build
+```
+
+## Updating Protobuf Definitions
+
+When updating the protobuf definitions in `internal/durabletask-protobuf/protos/orchestrator_service.proto`:
+
+1. Manually copy the updated protobuf file from dapr/durabletask-protobuf
+2. Update the commit hash in `internal/durabletask-protobuf/PROTO_SOURCE_COMMIT_HASH` to reflect the new commit
+3. Regenerate the Java classes from the protobuf definitions:
+
+```shell
+./gradlew generateProto
 ```

internal/durabletask-protobuf/PROTO_SOURCE_COMMIT_HASH

@@ -1 +1 @@
-cc00765eeb3307f8fdac7da610915d3a0757702b
+ce184193bcf2d4dcf643bcc934d3ea897c4c8c5c

internal/durabletask-protobuf/README.md

@@ -1,6 +1,6 @@
 # Durable Task Protobuf Files
 
-This directory contains the protocol buffer definitions used by the Durable Task Framework Java SDK. The files in this directory are automatically downloaded and updated during the build process from the [microsoft/durabletask-protobuf](https://github.com/microsoft/durabletask-protobuf) repository.
+This directory contains the protocol buffer definitions used by the Durable Task Framework Java SDK. The files in this directory are automatically downloaded and updated during the build process from the [dapr/durabletask-protobuf](https://github.com/dapr/durabletask-protobuf) repository.
 
 ## Directory Structure
 

internal/durabletask-protobuf/protos/orchestrator_service.proto

@@ -3,7 +3,7 @@
 
 syntax = "proto3";
 
-option csharp_namespace = "Microsoft.DurableTask.Protobuf";
+option csharp_namespace = "Dapr.DurableTask.Protobuf";
 option java_package = "io.dapr.durabletask.implementation.protobuf";
 option go_package = "/api/protos";
 
@@ -12,6 +12,11 @@ import "google/protobuf/duration.proto";
 import "google/protobuf/wrappers.proto";
 import "google/protobuf/empty.proto";
 
+message TaskRouter {
+    string source = 1; // orchestrationAppID
+    string target = 2; // appID
+}
+
 message OrchestrationInstance {
     string instanceId = 1;
     google.protobuf.StringValue executionId = 2;
@@ -192,10 +197,10 @@ message EntityOperationCalledEvent {
 }
 
 message EntityLockRequestedEvent {
-    string criticalSectionId = 1;  
+    string criticalSectionId = 1;
     repeated string lockSet = 2;
     int32 position = 3;
-    google.protobuf.StringValue parentInstanceId = 4; // used only within messages, null in histories 
+    google.protobuf.StringValue parentInstanceId = 4; // used only within messages, null in histories
 }
 
 message EntityOperationCompletedEvent {
@@ -210,14 +215,14 @@ message EntityOperationFailedEvent {
 
 message EntityUnlockSentEvent {
     string criticalSectionId = 1;
-    google.protobuf.StringValue parentInstanceId = 2;  // used only within messages, null in histories 
+    google.protobuf.StringValue parentInstanceId = 2;  // used only within messages, null in histories
     google.protobuf.StringValue targetInstanceId = 3;  // used only within histories, null in messages
 }
 
 message EntityLockGrantedEvent {
     string criticalSectionId = 1;
 }
- 
+
 message HistoryEvent {
     int32 eventId = 1;
     google.protobuf.Timestamp timestamp = 2;
@@ -244,25 +249,28 @@ message HistoryEvent {
         ExecutionResumedEvent executionResumed = 22;
         EntityOperationSignaledEvent entityOperationSignaled = 23;
         EntityOperationCalledEvent entityOperationCalled = 24;
-        EntityOperationCompletedEvent entityOperationCompleted = 25; 
-        EntityOperationFailedEvent entityOperationFailed = 26; 
+        EntityOperationCompletedEvent entityOperationCompleted = 25;
+        EntityOperationFailedEvent entityOperationFailed = 26;
         EntityLockRequestedEvent entityLockRequested = 27;
         EntityLockGrantedEvent entityLockGranted = 28;
         EntityUnlockSentEvent entityUnlockSent = 29;
     }
+    optional TaskRouter router = 30;
 }
 
 message ScheduleTaskAction {
     string name = 1;
     google.protobuf.StringValue version = 2;
     google.protobuf.StringValue input = 3;
+    optional TaskRouter router = 4;
 }
 
 message CreateSubOrchestrationAction {
     string instanceId = 1;
     string name = 2;
     google.protobuf.StringValue version = 3;
     google.protobuf.StringValue input = 4;
+    optional TaskRouter router = 5;
 }
 
 message CreateTimerAction {
@@ -311,6 +319,7 @@ message OrchestratorAction {
         TerminateOrchestrationAction terminateOrchestration = 7;
         SendEntityMessageAction sendEntityMessage = 8;
     }
+    optional TaskRouter router = 9;
 }
 
 message OrchestratorRequest {
@@ -320,6 +329,7 @@ message OrchestratorRequest {
     repeated HistoryEvent newEvents = 4;
     OrchestratorEntityParameters entityParameters = 5;
     bool requiresHistoryStreaming = 6;
+    optional TaskRouter router = 7;
 }
 
 message OrchestratorResponse {