@@ -236,7 +236,7 @@ def __init__(
236
236
Whether this is a SQS, DynamoDB Streams, or Kinesis Data Stream event
237
237
model: Optional["BatchTypeModels"]
238
238
Parser's data model using either SqsRecordModel, DynamoDBStreamRecordModel, KinesisDataStreamRecord
239
- raise_on_entire_batch_fail : bool
239
+ raise_on_entire_batch_failure : bool
240
240
Raise an exception when the entire batch has failed processing.
241
241
When set to False, partial failures are reported in the response
242
242
@@ -247,7 +247,7 @@ def __init__(
247
247
"""
248
248
self .event_type = event_type
249
249
self .model = model
250
- self .raise_on_entire_batch_fail = raise_on_entire_batch_failure
250
+ self .raise_on_entire_batch_failure = raise_on_entire_batch_failure
251
251
self .batch_response : PartialItemFailureResponse = copy .deepcopy (self .DEFAULT_RESPONSE )
252
252
self ._COLLECTOR_MAPPING = {
253
253
EventType .SQS : self ._collect_sqs_failures ,
@@ -283,7 +283,7 @@ def _clean(self):
283
283
if not self ._has_messages_to_report ():
284
284
return
285
285
286
- if self ._entire_batch_failed () and self .raise_on_entire_batch_fail :
286
+ if self ._entire_batch_failed () and self .raise_on_entire_batch_failure :
287
287
raise BatchProcessingError (
288
288
msg = f"All records failed processing. { len (self .exceptions )} individual errors logged "
289
289
f"separately below." ,
0 commit comments