@@ -156,7 +156,7 @@ def batch_processor(
156
156
157
157
158
158
class BatchProcessor (BasePartialProcessor ):
159
- DEFAULT_REPORT = {"batchItemFailures" : []}
159
+ DEFAULT_RESPONSE : Dict [ str , List [ Optional [ dict ]]] = {"batchItemFailures" : []}
160
160
161
161
def __init__ (self , event_type : EventType ):
162
162
"""Process batch and partially report failed items
@@ -168,21 +168,21 @@ def __init__(self, event_type: EventType):
168
168
"""
169
169
# refactor: Bring boto3 etc. for deleting permanent exceptions
170
170
self .event_type = event_type
171
- self .items_to_report : Dict [ str , List [ Optional [ dict ]]] = self .DEFAULT_REPORT
171
+ self .batch_response = self .DEFAULT_RESPONSE
172
172
173
173
super ().__init__ ()
174
174
175
175
def response (self ):
176
- """Response containing batch items that failed processing, if any"""
177
- return self .items_to_report
176
+ """Batch items that failed processing, if any"""
177
+ return self .batch_response
178
178
179
179
def _prepare (self ):
180
180
"""
181
181
Remove results from previous execution.
182
182
"""
183
183
self .success_messages .clear ()
184
184
self .fail_messages .clear ()
185
- self .items_to_report = self .DEFAULT_REPORT
185
+ self .batch_response = self .DEFAULT_RESPONSE
186
186
187
187
def _process_record (self , record ) -> Tuple :
188
188
"""
@@ -208,9 +208,7 @@ def _clean(self):
208
208
return
209
209
210
210
messages = self ._get_messages_to_report ()
211
- self .items_to_report ["batchItemFailures" ].append (messages )
212
-
213
- return self .items_to_report
211
+ self .batch_response = {"batchItemFailures" : [messages ]}
214
212
215
213
def _has_messages_to_report (self ) -> bool :
216
214
if self .fail_messages :
0 commit comments