File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -17,7 +17,8 @@ async def main() -> None:
1717 request_list_sources_input = request_list_sources ,
1818 )
1919
20- Actor .log .info (f'Loaded { len (request_list .requests )} requests from input' )
20+ total = await request_list .get_total_count ()
21+ Actor .log .info (f'Loaded { total } requests from input' )
2122
2223 # Process requests from the list
2324 while request := await request_list .fetch_next_request ():
Original file line number Diff line number Diff line change @@ -14,7 +14,7 @@ async def main() -> None:
1414 Actor .log .info (f'Resuming from item { start_index } ' )
1515
1616 # Do some work and update the state — it is persisted automatically
17- for i in range (start_index , 100 ):
17+ for i in range (start_index , 100 ): # type: ignore[arg-type]
1818 Actor .log .info (f'Processing item { i } ...' )
1919 state ['processed_items' ] = i + 1
2020 await asyncio .sleep (0.1 )
You can’t perform that action at this time.
0 commit comments