Include Exception Properties at FailureDetails

Directory.Packages.props

@@ -29,7 +29,7 @@
 
   <!-- DurableTask Packages -->
   <ItemGroup>
-    <PackageVersion Include="Microsoft.Azure.DurableTask.Core" Version="3.4.0" />
+    <PackageVersion Include="Microsoft.Azure.DurableTask.Core" Version="3.5.0" />
     <PackageVersion Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask" Version="1.2.2" />
   </ItemGroup>
 

eng/targets/Release.props

@@ -17,7 +17,7 @@
   </PropertyGroup>
 
   <PropertyGroup>
-    <VersionPrefix>1.15.1</VersionPrefix>
+    <VersionPrefix>1.16.0</VersionPrefix>
     <VersionSuffix></VersionSuffix>
   </PropertyGroup>
 

src/Abstractions/DurableTaskCoreExceptionsExtensions.cs

@@ -49,6 +49,7 @@ static class DurableTaskCoreExceptionsExtensions
             failureDetails.ErrorType,
             failureDetails.ErrorMessage,
             failureDetails.StackTrace,
-            failureDetails.InnerFailure?.ToTaskFailureDetails());
+            failureDetails.InnerFailure?.ToTaskFailureDetails(),
+            failureDetails.Properties);
     }
 }

src/Abstractions/TaskFailureDetails.cs

@@ -15,7 +15,8 @@ namespace Microsoft.DurableTask;
 /// <param name="ErrorMessage">A summary description of the failure.</param>
 /// <param name="StackTrace">The stack trace of the failure.</param>
 /// <param name="InnerFailure">The inner cause of the task failure.</param>
-public record TaskFailureDetails(string ErrorType, string ErrorMessage, string? StackTrace, TaskFailureDetails? InnerFailure)
+/// <param name="Properties">Additional properties associated with the exception.</param>
+public record TaskFailureDetails(string ErrorType, string ErrorMessage, string? StackTrace, TaskFailureDetails? InnerFailure, IDictionary<string, object?>? Properties)
 {
     Type? loadedExceptionType;
 
@@ -123,7 +124,8 @@ internal CoreFailureDetails ToCoreFailureDetails()
             this.ErrorMessage,
             this.StackTrace,
             this.InnerFailure?.ToCoreFailureDetails(),
-            isNonRetriable: false);
+            isNonRetriable: false,
+            this.Properties);
     }
 
     /// <summary>
@@ -143,7 +145,8 @@ internal CoreFailureDetails ToCoreFailureDetails()
             coreFailureDetails.ErrorType,
             coreFailureDetails.ErrorMessage,
             coreFailureDetails.StackTrace,
-            FromCoreFailureDetails(coreFailureDetails.InnerFailure));
+            FromCoreFailureDetails(coreFailureDetails.InnerFailure),
+            coreFailureDetails.Properties);
     }
 
     [return: NotNullIfNotNull(nameof(exception))]
@@ -160,14 +163,17 @@ internal CoreFailureDetails ToCoreFailureDetails()
                 coreEx.FailureDetails?.ErrorType ?? "(unknown)",
                 coreEx.FailureDetails?.ErrorMessage ?? "(unknown)",
                 coreEx.FailureDetails?.StackTrace,
-                FromCoreFailureDetailsRecursive(coreEx.FailureDetails?.InnerFailure) ?? FromExceptionRecursive(coreEx.InnerException));
+                FromCoreFailureDetailsRecursive(coreEx.FailureDetails?.InnerFailure) ?? FromExceptionRecursive(coreEx.InnerException),
+                coreEx.FailureDetails?.Properties);
         }
 
+        // might need to udpate this later
         return new TaskFailureDetails(
             exception.GetType().ToString(),
             exception.Message,
             exception.StackTrace,
-            FromExceptionRecursive(exception.InnerException));
+            FromExceptionRecursive(exception.InnerException),
+            null);
     }
 
     static TaskFailureDetails? FromCoreFailureDetailsRecursive(CoreFailureDetails? coreFailureDetails)
@@ -181,6 +187,7 @@ internal CoreFailureDetails ToCoreFailureDetails()
             coreFailureDetails.ErrorType,
             coreFailureDetails.ErrorMessage,
             coreFailureDetails.StackTrace,
-            FromCoreFailureDetailsRecursive(coreFailureDetails.InnerFailure));
+            FromCoreFailureDetailsRecursive(coreFailureDetails.InnerFailure),
+            coreFailureDetails.Properties);
     }
 }

src/Client/OrchestrationServiceClientShim/ShimExtensions.cs

@@ -75,7 +75,7 @@ public static Core.OrchestrationStatus ConvertToCore(this OrchestrationRuntimeSt
         }
 
         TaskFailureDetails? inner = details.InnerFailure?.ConvertFromCore();
-        return new TaskFailureDetails(details.ErrorType, details.ErrorMessage, details.StackTrace, inner);
+        return new TaskFailureDetails(details.ErrorType, details.ErrorMessage, details.StackTrace, inner, details.Properties);
     }
 
     /// <summary>

src/Grpc/orchestrator_service.proto

@@ -41,6 +41,7 @@ message TaskFailureDetails {
     google.protobuf.StringValue stackTrace = 3;
     TaskFailureDetails innerFailure = 4;
     bool isNonRetriable = 5;
+    map<string, google.protobuf.Value> properties = 6;
 }
 
 enum OrchestrationStatus {
@@ -469,6 +470,7 @@ message PurgeInstancesRequest {
     oneof request {
         string instanceId = 1;
         PurgeInstanceFilter purgeInstanceFilter = 2;
+        InstanceBatch instanceBatch = 4;
     }
     bool recursive = 3;
 }
@@ -681,8 +683,7 @@ message AbandonEntityTaskResponse {
 }
 
 message SkipGracefulOrchestrationTerminationsRequest {
-    // A maximum of 500 instance IDs can be provided in this list.
-    repeated string instanceIds = 1;
+    InstanceBatch instanceBatch = 1;
     google.protobuf.StringValue reason = 2;
 }
 
@@ -818,4 +819,9 @@ message StreamInstanceHistoryRequest {
 
 message HistoryChunk {
     repeated HistoryEvent events = 1;
+}
+
+message InstanceBatch {
+    // A maximum of 500 instance IDs can be provided in this list.
+    repeated string instanceIds = 1;
 }

src/Grpc/versions.txt

@@ -1,2 +1,2 @@
-# The following files were downloaded from branch main at 2025-09-17 01:45:58 UTC
-https://raw.githubusercontent.com/microsoft/durabletask-protobuf/f5745e0d83f608d77871c1894d9260ceaae08967/protos/orchestrator_service.proto
+# The following files were downloaded from branch main at 2025-10-13 18:06:55 UTC
+https://raw.githubusercontent.com/microsoft/durabletask-protobuf/97cf9cf6ac44107b883b0f4ab1dd62ee2332cfd9/protos/orchestrator_service.proto