@@ -69,8 +69,8 @@ def __init__(self, model: Optional["BatchSqsTypeModel"] = None, skip_group_on_er
69
69
model: Optional["BatchSqsTypeModel"]
70
70
An optional model for batch processing.
71
71
skip_group_on_error: bool
72
- # TODO: Alterar
73
- Determine whether to return on the first error encountered. Default is True
72
+ Determines whether to exclusively skip messages from the MessageGroupID that encountered processing failures
73
+ Default is False
74
74
75
75
"""
76
76
self ._skip_group_on_error = skip_group_on_error
@@ -82,7 +82,7 @@ def process(self) -> List[Tuple]:
82
82
the process is short-circuited, and the remaining messages are reported as failed items.
83
83
"""
84
84
result : List [Tuple ] = []
85
- skip_messages_group_id : List = []
85
+ skip_message_ids : List = []
86
86
87
87
for i , record in enumerate (self .records ):
88
88
# If we have failed messages and we are set to return on the first error,
@@ -95,21 +95,21 @@ def process(self) -> List[Tuple]:
95
95
96
96
# skip_group_on_error is True:
97
97
# Skip processing the current message if its ID belongs to a group with failed messages
98
- if msg_id in skip_messages_group_id :
98
+ if msg_id in skip_message_ids :
99
99
logger .debug (
100
100
f"Skipping message with ID '{ msg_id } ' as it is part of a group containing failed messages." ,
101
101
)
102
102
continue
103
103
104
- processed_messages = self ._process_record (record )
104
+ processed_message = self ._process_record (record )
105
105
106
106
# If a processed message fail and skip_group_on_error is True,
107
107
# mark subsequent messages from the same MessageGroupId as skipped
108
- if processed_messages [0 ] == "fail" and self ._skip_group_on_error :
109
- self ._process_failed_subsequent_messages (record , i , skip_messages_group_id , result )
108
+ if processed_message [0 ] == "fail" and self ._skip_group_on_error :
109
+ self ._process_failed_subsequent_messages (record , i , skip_message_ids , result )
110
110
111
111
# Append the processed message normally
112
- result .append (processed_messages )
112
+ result .append (processed_message )
113
113
114
114
return result
115
115
0 commit comments