added a test

Author: Sophia Tevosyan

src/InProcessTestHost/Sidecar/Grpc/ProtobufUtils.cs

@@ -288,7 +288,7 @@ public static OrchestratorAction ToOrchestratorAction(Proto.OrchestratorAction a
                     ParentTraceContext = a.CreateSubOrchestration.ParentTraceContext is not null
                         ? new DistributedTraceContext(a.CreateSubOrchestration.ParentTraceContext.TraceParent, a.CreateSubOrchestration.ParentTraceContext.TraceState)
                         : null,
-                    Tags = null, // TODO
+                    Tags = a.CreateSubOrchestration.Tags,
                     Version = a.CreateSubOrchestration.Version,
                 };
             case Proto.OrchestratorAction.OrchestratorActionTypeOneofCase.CreateTimer:

src/Worker/Core/Shims/TaskOrchestrationContextWrapper.cs

@@ -235,7 +235,8 @@ public override async Task<TResult> CallSubOrchestratorAsync<TResult>(
                         orchestratorName.Name,
                         version,
                         instanceId,
-                        input),
+                        input,
+                        options?.Tags),
                     orchestratorName.Name,
                     handler,
                     default);
@@ -246,7 +247,8 @@ public override async Task<TResult> CallSubOrchestratorAsync<TResult>(
                     orchestratorName.Name,
                     version,
                     instanceId,
-                    input);
+                    input,
+                    options?.Tags);
             }
         }
         catch (global::DurableTask.Core.Exceptions.SubOrchestrationFailedException e)

test/Grpc.IntegrationTests/OrchestrationPatterns.cs

@@ -36,7 +36,7 @@ public async Task EmptyOrchestration()
     }
 
     [Fact]
-    public async Task ScheduleOrchesrationWithTags()
+    public async Task ScheduleOrchestrationWithTags()
     {
         TaskName orchestratorName = nameof(EmptyOrchestration);
         await using HostTestLifetime server = await this.StartWorkerAsync(b =>
@@ -67,6 +67,52 @@ public async Task ScheduleOrchesrationWithTags()
         Assert.Equal("value2", metadata.Tags["tag2"]);
     }
 
+    [Fact]
+    public async Task ScheduleSubOrchestrationWithTags()
+    {
+        TaskName orchestratorName = nameof(ScheduleSubOrchestrationWithTags);
+
+        // Schedule a new orchestration instance with tags
+        SubOrchestrationOptions subOrchestrationOptions = new()
+        {
+            InstanceId = "instance_id",
+            Tags = new Dictionary<string, string>
+            {
+                { "tag1", "value1" },
+                { "tag2", "value2" }
+            }
+        };
+
+        await using HostTestLifetime server = await this.StartWorkerAsync(b =>
+        {
+            b.AddTasks(tasks => tasks.AddOrchestratorFunc<int, int>(orchestratorName, async (ctx, input) =>
+            {
+                int result = 1;
+                if (input < 2)
+                {
+                    // recursively call this same orchestrator
+                    result += await ctx.CallSubOrchestratorAsync<int>(orchestratorName, input: input + 1, subOrchestrationOptions);
+                }
+
+                return result;
+            }));
+        });
+
+
+        await server.Client.ScheduleNewOrchestrationInstanceAsync(orchestratorName, input: 1);
+
+        OrchestrationMetadata metadata = await server.Client.WaitForInstanceCompletionAsync(
+            subOrchestrationOptions.InstanceId, this.TimeoutToken);
+
+        Assert.NotNull(metadata);
+        Assert.Equal(subOrchestrationOptions.InstanceId, metadata.InstanceId);
+        Assert.Equal(OrchestrationRuntimeStatus.Completed, metadata.RuntimeStatus);
+        Assert.NotNull(metadata.Tags);
+        Assert.Equal(2, metadata.Tags.Count);
+        Assert.Equal("value1", metadata.Tags["tag1"]);
+        Assert.Equal("value2", metadata.Tags["tag2"]);
+    }
+
     [Fact]
     public async Task SingleTimer()
     {