use dts

Author: YunchuWang

samples/EventsSample/EventsSample.csproj

@@ -12,8 +12,8 @@
 
   <ItemGroup>
     <!-- Using p2p references so we can show latest changes in samples. -->
-    <ProjectReference Include="$(SrcRoot)Client/Grpc/Client.Grpc.csproj" />
-    <ProjectReference Include="$(SrcRoot)Worker/Grpc/Worker.Grpc.csproj" />
+    <ProjectReference Include="$(SrcRoot)Client/AzureManaged/Client.AzureManaged.csproj" />
+    <ProjectReference Include="$(SrcRoot)Worker/AzureManaged/Worker.AzureManaged.csproj" />
 
     <!-- Reference the source generator -->
     <ProjectReference Include="$(SrcRoot)Generators/Generators.csproj" 

samples/EventsSample/Program.cs

@@ -6,22 +6,32 @@
 using EventsSample;
 using Microsoft.DurableTask;
 using Microsoft.DurableTask.Client;
+using Microsoft.DurableTask.Client.AzureManaged;
 using Microsoft.DurableTask.Worker;
+using Microsoft.DurableTask.Worker.AzureManaged;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 
 HostApplicationBuilder builder = Host.CreateApplicationBuilder(args);
 
-builder.Services.AddDurableTaskClient().UseGrpc();
-builder.Services.AddDurableTaskWorker()
-    .AddTasks(tasks =>
+string schedulerConnectionString = builder.Configuration.GetValue<string>("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
+    ?? throw new InvalidOperationException("DURABLE_TASK_SCHEDULER_CONNECTION_STRING is not set.");
+
+builder.Services.AddDurableTaskClient(clientBuilder => clientBuilder.UseDurableTaskScheduler(schedulerConnectionString));
+
+builder.Services.AddDurableTaskWorker(workerBuilder =>
+{
+    workerBuilder.AddTasks(tasks =>
     {
         tasks.AddOrchestrator<ApprovalOrchestrator>();
         tasks.AddActivity<NotifyApprovalRequiredActivity>();
         tasks.AddOrchestrator<DataProcessingOrchestrator>();
         tasks.AddActivity<ProcessDataActivity>();
-    })
-    .UseGrpc();
+    });
+
+    workerBuilder.UseDurableTaskScheduler(schedulerConnectionString);
+});
 
 IHost host = builder.Build();
 await host.StartAsync();

samples/EventsSample/README.md

@@ -63,11 +63,16 @@ await client.RaiseEventAsync(
 
 ## Running the Sample
 
-1. Ensure you have the Durable Task sidecar running (if using gRPC mode)
+This sample is configured to use **Durable Task Scheduler (DTS)** (no local gRPC sidecar required).
+
+1. Set the DTS connection string:
+    ```bash
+    export DURABLE_TASK_SCHEDULER_CONNECTION_STRING="..."
+    ```
 2. Run the sample:
-   ```bash
-   dotnet run
-   ```
+    ```bash
+    dotnet run
+    ```
 
 The sample will:
 1. Start an approval workflow and wait for an approval event