"""Sliding Window Batch Processing Sample.

This sample demonstrates a batch processing workflow that maintains a sliding window

of record processing workflows. It includes:

- ProcessBatchWorkflow: Main workflow that partitions work across multiple sliding windows

- SlidingWindowWorkflow: Implements the sliding window pattern with continue-as-new

- RecordProcessorWorkflow: Processes individual records

- RecordLoader: Activity for loading records from external sources

"""

from batch_sliding_window.batch_workflow import (

ProcessBatchWorkflow,

ProcessBatchWorkflowInput,

)

from batch_sliding_window.record_loader_activity import (

GetRecordsInput,

GetRecordsOutput,

RecordLoader,

SingleRecord,

)

from batch_sliding_window.record_processor_workflow import RecordProcessorWorkflow

from batch_sliding_window.sliding_window_workflow import (

SlidingWindowState,

SlidingWindowWorkflow,

SlidingWindowWorkflowInput,

)

__all__ = [

"ProcessBatchWorkflow",

"ProcessBatchWorkflowInput",

"SlidingWindowWorkflow",

"SlidingWindowWorkflowInput",

"SlidingWindowState",

"RecordProcessorWorkflow",

"RecordLoader",

"GetRecordsInput",

"GetRecordsOutput",

"SingleRecord",

]