fb

Author: YunchuWang

samples/ScheduleWebApp/Orchestrations/CacheClearingOrchestrator.cs

@@ -15,7 +15,7 @@ public override async Task<string> RunAsync(TaskOrchestrationContext context, st
         {
             logger.LogInformation("Starting CacheClearingOrchestration for schedule ID: {ScheduleId}", scheduleId);
 
-            CallActivityOptions options = new CallActivityOptions(tags: new Dictionary<string, string>
+            TaskOptions options = new TaskOptions(tags: new Dictionary<string, string>
             {
                 { "scheduleId", scheduleId }
             });

src/Abstractions/TaskOptions.cs

@@ -135,29 +135,3 @@ public record StartOrchestrationOptions(string? InstanceId = null, DateTimeOffse
     /// </summary>
     public TaskVersion? Version { get; init; }
 }
-
-/// <summary>
-/// Options for calling activities from an orchestrator.
-/// </summary>
-public record CallActivityOptions : TaskOptions
-{
-    /// <summary>
-    /// Initializes a new instance of the <see cref="CallActivityOptions"/> class.
-    /// </summary>
-    /// <param name="retry">The task retry options.</param>
-    /// <param name="tags">The tags to associate with the activity.</param>
-    public CallActivityOptions(TaskRetryOptions? retry = null, IDictionary<string, string>? tags = null)
-        : base(retry, tags)
-    {
-    }
-
-    /// <summary>
-    /// Initializes a new instance of the <see cref="CallActivityOptions"/> class.
-    /// </summary>
-    /// <param name="options">The task options to wrap.</param>
-    /// <param name="tags">The tags to associate with the activity.</param>
-    public CallActivityOptions(TaskOptions options, IDictionary<string, string>? tags = null)
-        : base(options.Retry, tags ?? options.Tags)
-    {
-    }
-}

src/Worker/Core/Shims/TaskOrchestrationContextWrapper.cs

@@ -138,8 +138,8 @@ public override async Task<T> CallActivityAsync<T>(
 
         try
         {
-            IDictionary<string, string>? tags = new Dictionary<string, string>();
-            if (options is CallActivityOptions callActivityOptions)
+            IDictionary<string, string> tags = new Dictionary<string, string>();
+            if (options is TaskOptions callActivityOptions)
             {
                 if (callActivityOptions.Tags is not null)
                 {