From d5806d077d174cc45631175b4ff96779ba9ba96c Mon Sep 17 00:00:00 2001
From: Tomer Rosenthal <17064840+torosent@users.noreply.github.com>
Date: Wed, 1 Jul 2026 10:50:35 -0700
Subject: [PATCH] Set Python large payload sample threshold to 256 KiB

Align the Durable Task SDK Python sample with the SDK default change
(microsoft/durabletask-python#166): set threshold_bytes to 262,144
(256 KiB) in both worker and client, and raise the demo payload
(input 10_000 -> 50_000, ~342 KB) so it still exceeds the threshold
and externalizes.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
---
 samples/durable-task-sdks/python/large-payload/README.md | 6 +++---
 samples/durable-task-sdks/python/large-payload/client.py | 4 ++--
 samples/durable-task-sdks/python/large-payload/worker.py | 6 +++---
 3 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/samples/durable-task-sdks/python/large-payload/README.md b/samples/durable-task-sdks/python/large-payload/README.md
index 20d0d20e..206a0adb 100644
--- a/samples/durable-task-sdks/python/large-payload/README.md
+++ b/samples/durable-task-sdks/python/large-payload/README.md
@@ -168,7 +168,7 @@ Result: "Processed 10000 records (70000 bytes)"
 Done!
 ```
 
-Both orchestrations produce the same type of result. The difference is invisible to the application code — the SDK transparently externalizes the 70 KB payload to blob storage and retrieves it when needed.
+Both orchestrations produce the same type of result. The difference is invisible to the application code — the SDK transparently externalizes the ~342 KB payload to blob storage and retrieves it when needed.
 
 ## Code Walkthrough
 
@@ -179,13 +179,13 @@ The `BlobPayloadStore` is configured with a `BlobPayloadStoreOptions` object:
 ```python
 store = BlobPayloadStore(BlobPayloadStoreOptions(
     connection_string=storage_conn_str,
-    threshold_bytes=1_024,  # Externalize payloads larger than 1 KB
+    threshold_bytes=262_144,  # Externalize payloads larger than 256 KiB
 ))
 ```
 
 Key options:
 - **`connection_string`**: Azure Storage connection string (or `UseDevelopmentStorage=true` for Azurite)
-- **`threshold_bytes`**: Payloads larger than this are externalized (default: 900 KB)
+- **`threshold_bytes`**: Payloads larger than this are externalized (default: 256 KiB)
 - **`max_stored_payload_bytes`**: Maximum payload size that can be stored (default: 10 MB)
 - **`enable_compression`**: Whether to compress payloads with GZip before storing (default: `True`)
 - **`container_name`**: Blob container name (default: `durabletask-payloads`)
diff --git a/samples/durable-task-sdks/python/large-payload/client.py b/samples/durable-task-sdks/python/large-payload/client.py
index ba90d3bc..3f793788 100644
--- a/samples/durable-task-sdks/python/large-payload/client.py
+++ b/samples/durable-task-sdks/python/large-payload/client.py
@@ -31,7 +31,7 @@ async def main():
     # Configure the blob payload store — must match the worker configuration
     store = BlobPayloadStore(BlobPayloadStoreOptions(
         connection_string=storage_conn_str,
-        threshold_bytes=1_024,
+        threshold_bytes=262_144,
     ))
 
     # Set credential to None for emulator, or DefaultAzureCredential for Azure
@@ -61,7 +61,7 @@ async def main():
     # --- Large payload (externalized to blob storage) ---
     print("\n--- Large payload (externalized to blob storage) ---")
     instance_id = client.schedule_new_orchestration(
-        "large_payload_orchestrator", input=10_000
+        "large_payload_orchestrator", input=50_000
     )
     logger.info(f"Scheduled orchestration with ID: {instance_id}")
 
diff --git a/samples/durable-task-sdks/python/large-payload/worker.py b/samples/durable-task-sdks/python/large-payload/worker.py
index 0374e5f4..c00ab813 100644
--- a/samples/durable-task-sdks/python/large-payload/worker.py
+++ b/samples/durable-task-sdks/python/large-payload/worker.py
@@ -61,11 +61,11 @@ async def main():
     print(f"Using taskhub: {taskhub_name}")
     print(f"Using endpoint: {endpoint}")
 
-    # Configure the blob payload store with a low threshold for demo purposes
+    # Configure the blob payload store (256 KiB threshold, matching the SDK default)
     store = BlobPayloadStore(BlobPayloadStoreOptions(
         connection_string=storage_conn_str,
-        # Use a low threshold so that externalization is visible in the demo
-        threshold_bytes=1_024,
+        # 256 KiB, matching the SDK default; larger payloads are externalized
+        threshold_bytes=262_144,
     ))
 
     # Set credential to None for emulator, or DefaultAzureCredential for Azure