refactor, change folder name, fix imports and update readme to match style

Author: billrich2001

README.md

@@ -56,6 +56,7 @@ Some examples require extra dependencies. See each sample's directory for specif
   * [hello_signal](hello/hello_signal.py) - Send signals to a workflow.
 <!-- Keep this list in alphabetical order -->
 * [activity_worker](activity_worker) - Use Python activities from a workflow in another language.
+* [batch_sliding_window](batch_sliding_window) - Batch processing with a sliding window of child workflows.
 * [bedrock](bedrock) - Orchestrate a chatbot with Amazon Bedrock.
 * [cloud_export_to_parquet](cloud_export_to_parquet) - Set up schedule workflow to process exported files on an hourly basis
 * [context_propagation](context_propagation) - Context propagation through workflows/activities via interceptor.

batch-sliding-window/README.md

@@ -0,0 +1,21 @@
+# Batch Sliding Window
+
+This sample demonstrates a batch processing workflow that maintains a sliding window of record processing workflows.
+
+A `SlidingWindowWorkflow` starts a configured number (sliding window size) of `RecordProcessorWorkflow` children in parallel. Each child processes a single record. When a child completes, a new child is started.
+
+The `SlidingWindowWorkflow` calls continue-as-new after starting a preconfigured number of children to keep its history size bounded. A `RecordProcessorWorkflow` reports its completion through a signal to its parent, which allows notification of a parent that called continue-as-new.
+
+A single instance of `SlidingWindowWorkflow` has limited window size and throughput. To support larger window size and overall throughput, multiple instances of `SlidingWindowWorkflow` run in parallel.
+
+### Running This Sample
+
+To run, first see [README.md](../README.md) for prerequisites. Then, run the following from this directory to start the worker:
+
+    uv run run_worker.py
+
+This will start the worker. Then, in another terminal, run the following to execute the workflow:
+
+    uv run run_starter.py
+
+The workflow will process 90 records using a sliding window of 10 parallel workers across 3 partitions, with a page size of 5 records per continue-as-new iteration. 

batch_sliding_window/README.md

@@ -9,14 +9,14 @@
 - RecordLoader: Activity for loading records from external sources
 """
 
-from .batch_workflow import ProcessBatchWorkflow, ProcessBatchWorkflowInput
-from .sliding_window_workflow import (
+from batch_sliding_window.batch_workflow import ProcessBatchWorkflow, ProcessBatchWorkflowInput
+from batch_sliding_window.sliding_window_workflow import (
     SlidingWindowWorkflow,
     SlidingWindowWorkflowInput,
     SlidingWindowState,
 )
-from .record_processor_workflow import RecordProcessorWorkflow
-from .record_loader_activity import (
+from batch_sliding_window.record_processor_workflow import RecordProcessorWorkflow
+from batch_sliding_window.record_loader_activity import (
     RecordLoader,
     GetRecordsInput,
     GetRecordsOutput,

batch-sliding-window/__init__.py batch_sliding_window/__init__.pybatch-sliding-window/__init__.py renamed to batch_sliding_window/__init__.py

@@ -6,8 +6,8 @@
 from temporalio.common import WorkflowIDReusePolicy
 from temporalio.exceptions import ApplicationError
 
-from .record_loader_activity import RecordLoader
-from .sliding_window_workflow import SlidingWindowWorkflow, SlidingWindowWorkflowInput
+from batch_sliding_window.record_loader_activity import RecordLoader
+from batch_sliding_window.sliding_window_workflow import SlidingWindowWorkflow, SlidingWindowWorkflowInput
 
 
 @dataclass

batch-sliding-window/batch_workflow.py batch_sliding_window/batch_workflow.pybatch-sliding-window/batch_workflow.py renamed to batch_sliding_window/batch_workflow.py

@@ -3,7 +3,7 @@
 
 from temporalio import workflow
 
-from .record_loader_activity import SingleRecord
+from batch_sliding_window.record_loader_activity import SingleRecord
 
 
 @workflow.defn

…sliding-window/record_loader_activity.py …sliding_window/record_loader_activity.pybatch-sliding-window/record_loader_activity.py renamed to batch_sliding_window/record_loader_activity.py batch-sliding-window/record_loader_activity.py renamed to batch_sliding_window/record_loader_activity.py

@@ -1,13 +1,8 @@
 #!/usr/bin/env python3
-"""Standalone starter for the batch sliding window sample."""
+"""Starter for the batch sliding window sample."""
 
 import asyncio
 import logging
-import sys
-from pathlib import Path
-
-# Add the python-samples directory to the path to enable imports
-sys.path.insert(0, str(Path(__file__).parent.parent))
 
 from temporalio.client import Client
 
@@ -35,8 +30,8 @@ async def main():
     handle = await client.start_workflow(
         ProcessBatchWorkflow.run,
         workflow_input,
-        id="batch-sliding-window-example",
-        task_queue="batch-sliding-window",
+        id="batch_sliding_window_example",
+        task_queue="batch_sliding_window",
     )
 
     print(f"Started workflow: {handle.id}")

…ding-window/record_processor_workflow.py …ding_window/record_processor_workflow.pybatch-sliding-window/record_processor_workflow.py renamed to batch_sliding_window/record_processor_workflow.py batch-sliding-window/record_processor_workflow.py renamed to batch_sliding_window/record_processor_workflow.py

@@ -1,13 +1,8 @@
 #!/usr/bin/env python3
-"""Standalone worker runner for the batch sliding window sample."""
+"""Worker for the batch sliding window sample."""
 
 import asyncio
 import logging
-import sys
-from pathlib import Path
-
-# Add the python-samples directory to the path to enable imports
-sys.path.insert(0, str(Path(__file__).parent.parent))
 
 from temporalio import worker
 from temporalio.client import Client
@@ -32,7 +27,7 @@ async def main():
     # Create worker
     temporal_worker = worker.Worker(
         client,
-        task_queue="batch-sliding-window",
+        task_queue="batch_sliding_window",
         workflows=[
             ProcessBatchWorkflow,
             SlidingWindowWorkflow,

batch-sliding-window/run_starter.py batch_sliding_window/run_starter.pybatch-sliding-window/run_starter.py renamed to batch_sliding_window/run_starter.py

@@ -5,8 +5,8 @@
 from temporalio import workflow
 from temporalio.common import WorkflowIDReusePolicy
 
-from .record_loader_activity import RecordLoader, GetRecordsInput, SingleRecord
-from .record_processor_workflow import RecordProcessorWorkflow
+from batch_sliding_window.record_loader_activity import RecordLoader, GetRecordsInput, SingleRecord
+from batch_sliding_window.record_processor_workflow import RecordProcessorWorkflow
 
 
 @dataclass