@@ -462,13 +462,14 @@ async def open_request_queue(
462
462
@overload
463
463
async def push_data (self , data : dict | list [dict ]) -> None : ...
464
464
@overload
465
- async def push_data (self , data : dict | list [dict ], event_name : str ) -> ChargeResult : ...
466
- async def push_data (self , data : dict | list [dict ], event_name : str | None = None ) -> ChargeResult | None :
465
+ async def push_data (self , data : dict | list [dict ], charged_event_name : str ) -> ChargeResult : ...
466
+ async def push_data (self , data : dict | list [dict ], charged_event_name : str | None = None ) -> ChargeResult | None :
467
467
"""Store an object or a list of objects to the default dataset of the current Actor run.
468
468
469
469
Args:
470
470
data: The data to push to the default dataset.
471
- event_name: If provided, the method will attempt to charge for the event for each pushed item.
471
+ charged_event_name: If provided and if the Actor uses the pay-per-event pricing model,
472
+ the method will attempt to charge for the event for each pushed item.
472
473
"""
473
474
self ._raise_if_not_initialized ()
474
475
@@ -478,8 +479,8 @@ async def push_data(self, data: dict | list[dict], event_name: str | None = None
478
479
data = data if isinstance (data , list ) else [data ]
479
480
480
481
max_charged_count = (
481
- self ._charging_manager .calculate_max_event_charge_count_within_limit (event_name )
482
- if event_name is not None
482
+ self ._charging_manager .calculate_max_event_charge_count_within_limit (charged_event_name )
483
+ if charged_event_name is not None
483
484
else None
484
485
)
485
486
@@ -491,9 +492,9 @@ async def push_data(self, data: dict | list[dict], event_name: str | None = None
491
492
else :
492
493
await dataset .push_data (data )
493
494
494
- if event_name :
495
+ if charged_event_name :
495
496
return await self ._charging_manager .charge (
496
- event_name = event_name ,
497
+ event_name = charged_event_name ,
497
498
count = min (max_charged_count , len (data )) if max_charged_count is not None else len (data ),
498
499
)
499
500
0 commit comments