fix

Author: YunchuWang

samples/ExceptionPropertiesSample/ExceptionPropertiesSample.csproj

@@ -19,7 +19,9 @@
   <ItemGroup>
     <!-- Using p2p references so we can show latest changes in samples. -->
     <ProjectReference Include="$(SrcRoot)Client/Grpc/Client.Grpc.csproj" />
+    <ProjectReference Include="$(SrcRoot)Client/AzureManaged/Client.AzureManaged.csproj" />
     <ProjectReference Include="$(SrcRoot)Worker/Grpc/Worker.Grpc.csproj" />
+    <ProjectReference Include="$(SrcRoot)Worker/AzureManaged/Worker.AzureManaged.csproj" />
   </ItemGroup>
 
 </Project>

samples/ExceptionPropertiesSample/Program.cs

@@ -5,23 +5,53 @@
 // TaskFailureDetails with custom exception properties for better diagnostics.
 
 using ExceptionPropertiesSample;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.DurableTask.Client;
+using Microsoft.DurableTask.Client.AzureManaged;
 using Microsoft.DurableTask.Worker;
+using Microsoft.DurableTask.Worker.AzureManaged;
 using Microsoft.Extensions.Hosting;
 
 HostApplicationBuilder builder = Host.CreateApplicationBuilder(args);
 
+string? schedulerConnectionString = builder.Configuration.GetValue<string>("DURABLE_TASK_SCHEDULER_CONNECTION_STRING");
+bool useScheduler = !string.IsNullOrWhiteSpace(schedulerConnectionString);
+
 // Register the durable task client
-builder.Services.AddDurableTaskClient().UseGrpc();
+if (useScheduler)
+{
+    builder.Services.AddDurableTaskClient(clientBuilder => clientBuilder.UseDurableTaskScheduler(schedulerConnectionString!));
+}
+else
+{
+    builder.Services.AddDurableTaskClient().UseGrpc();
+}
 
 // Register the durable task worker with custom exception properties provider
-builder.Services.AddDurableTaskWorker()
-    .AddTasks(tasks =>
+if (useScheduler)
+{
+    builder.Services.AddDurableTaskWorker(workerBuilder =>
     {
-        tasks.AddOrchestrator<ValidationOrchestration>();
-        tasks.AddActivity<ValidateInputActivity>();
-    })
-    .UseGrpc();
+        workerBuilder.AddTasks(tasks =>
+        {
+            tasks.AddOrchestrator<ValidationOrchestration>();
+            tasks.AddActivity<ValidateInputActivity>();
+        });
+
+        workerBuilder.UseDurableTaskScheduler(schedulerConnectionString!);
+    });
+}
+else
+{
+    builder.Services.AddDurableTaskWorker()
+        .AddTasks(tasks =>
+        {
+            tasks.AddOrchestrator<ValidationOrchestration>();
+            tasks.AddActivity<ValidateInputActivity>();
+        })
+        .UseGrpc();
+}
 
 // Register the custom exception properties provider
 // This will automatically extract custom properties from exceptions and include them in TaskFailureDetails
@@ -39,6 +69,11 @@
 Console.WriteLine("===========================");
 Console.WriteLine();
 
+Console.WriteLine(useScheduler
+    ? "Configured to use Durable Task Scheduler (DTS)."
+    : "Configured to use local gRPC. (Set DURABLE_TASK_SCHEDULER_CONNECTION_STRING to use DTS.)");
+Console.WriteLine();
+
 // Test case 1: Valid input (should succeed)
 Console.WriteLine("Test 1: Valid input");
 string instanceId1 = await client.ScheduleNewOrchestrationInstanceAsync(

samples/ExceptionPropertiesSample/README.md

@@ -22,6 +22,20 @@ When orchestrations or activities throw exceptions, the Durable Task framework c
 
 ## Running the Sample
 
+This sample can run against either:
+
+1. **Durable Task Scheduler (DTS)** (recommended): set the `DURABLE_TASK_SCHEDULER_CONNECTION_STRING` environment variable.
+2. **Local gRPC endpoint**: if the env var is not set, the sample uses the default local gRPC configuration.
+
+### DTS
+
+Set `DURABLE_TASK_SCHEDULER_CONNECTION_STRING` and run the sample.
+
+```cmd
+set DURABLE_TASK_SCHEDULER_CONNECTION_STRING=Endpoint=https://...;TaskHub=...;Authentication=...;
+dotnet run --project ExceptionPropertiesSample
+```
+
 ```bash
 dotnet run --project ExceptionPropertiesSample
 ```

samples/ExceptionPropertiesSample/appsettings.json

@@ -0,0 +1,3 @@
+{
+  "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": ""
+}