sample good

Author: YunchuWang

samples/LargePayloadConsoleApp/Program.cs

@@ -7,6 +7,7 @@
 using Microsoft.DurableTask.Entities;
 using Microsoft.DurableTask.Worker;
 using Microsoft.DurableTask.Worker.AzureManaged;
+using Microsoft.DurableTask;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;

samples/LargePayloadConsoleApp/Properties/launchSettings.json

@@ -0,0 +1,12 @@
+{
+  "profiles": {
+    "LargePayloadConsoleApp": {
+      "commandName": "Project",
+      "environmentVariables": {
+        "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": "",
+        "DURABLETASK_STORAGE": "",
+        "DURABLETASK_PAYLOAD_CONTAINER": ""
+      }
+    }
+  }
+}

samples/LargePayloadConsoleApp/run.ps1

@@ -280,6 +280,32 @@ async Task ResolveResponsePayloadsAsync<TResponse>(TResponse response, Cancellat
                     }
                 }
 
+                // Resolve entity V1 batch request (OperationRequest inputs and entity state)
+                if (wi.EntityRequest is { } er1)
+                {
+                    await this.MaybeResolveAsync(v => er1.EntityState = v, er1.EntityState, cancellation);
+                    if (er1.Operations != null)
+                    {
+                        foreach (P.OperationRequest op in er1.Operations)
+                        {
+                            await this.MaybeResolveAsync(v => op.Input = v, op.Input, cancellation);
+                        }
+                    }
+                }
+
+                // Resolve entity V2 request (history-based operation requests and entity state)
+                if (wi.EntityRequestV2 is { } er2)
+                {
+                    await this.MaybeResolveAsync(v => er2.EntityState = v, er2.EntityState, cancellation);
+                    if (er2.OperationRequests != null)
+                    {
+                        foreach (P.HistoryEvent opEvt in er2.OperationRequests)
+                        {
+                            await this.ResolveEventPayloadsAsync(opEvt, cancellation);
+                        }
+                    }
+                }
+
                 break;
         }
     }