File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1313 ProcessBatchWorkflow ,
1414 ProcessBatchWorkflowInput ,
1515)
16- from batch_sliding_window .sliding_window_workflow import (
17- SlidingWindowWorkflow ,
18- SlidingWindowWorkflowInput ,
19- SlidingWindowState ,
20- )
21- from batch_sliding_window .record_processor_workflow import RecordProcessorWorkflow
2216from batch_sliding_window .record_loader_activity import (
23- RecordLoader ,
2417 GetRecordsInput ,
2518 GetRecordsOutput ,
19+ RecordLoader ,
2620 SingleRecord ,
2721)
22+ from batch_sliding_window .record_processor_workflow import RecordProcessorWorkflow
23+ from batch_sliding_window .sliding_window_workflow import (
24+ SlidingWindowState ,
25+ SlidingWindowWorkflow ,
26+ SlidingWindowWorkflowInput ,
27+ )
2828
2929__all__ = [
3030 "ProcessBatchWorkflow" ,
Original file line number Diff line number Diff line change 1+ import asyncio
12from dataclasses import dataclass
23from typing import List
3- import asyncio
44
55from temporalio import workflow
66from temporalio .common import WorkflowIDReusePolicy
Original file line number Diff line number Diff line change 66from temporalio .common import WorkflowIDReusePolicy
77
88from batch_sliding_window .record_loader_activity import (
9- RecordLoader ,
109 GetRecordsInput ,
10+ RecordLoader ,
1111 SingleRecord ,
1212)
1313from batch_sliding_window .record_processor_workflow import RecordProcessorWorkflow
Original file line number Diff line number Diff line change 88from temporalio .client import Client
99
1010from batch_sliding_window .batch_workflow import ProcessBatchWorkflow
11- from batch_sliding_window .sliding_window_workflow import SlidingWindowWorkflow
12- from batch_sliding_window .record_processor_workflow import RecordProcessorWorkflow
1311from batch_sliding_window .record_loader_activity import RecordLoader
12+ from batch_sliding_window .record_processor_workflow import RecordProcessorWorkflow
13+ from batch_sliding_window .sliding_window_workflow import SlidingWindowWorkflow
1414
1515
1616async def main ():
You can’t perform that action at this time.
0 commit comments