Skip to content

Commit

Permalink
refactor: rename process entry function
Browse files Browse the repository at this point in the history
  • Loading branch information
maxhoheiser committed Apr 29, 2024
1 parent 5d6b823 commit da0f12a
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions localstack/services/events/provider_v2.py
Expand Up @@ -436,10 +436,10 @@ def put_events(
endpoint_id: EndpointId = None,
**kwargs,
) -> PutEventsResponse:
entries_uuids, failed_entries = self._put_entries(context, entries)
processed_entries_uuids, failed_entries = self._process_entries(context, entries)

response = PutEventsResponse(
Entries=[{"EventId": id} for id in entries_uuids], FailedEntryCount=0
Entries=[{"EventId": id} for id in processed_entries_uuids], FailedEntryCount=0
)
if failed_entries:
response["FailedEntryCount"] = len(failed_entries)
Expand Down Expand Up @@ -635,15 +635,15 @@ def _delete_target_sender(self, ids: TargetIdList, rule) -> None:
except KeyError:
LOG.error(f"Error deleting target service {target_arn}.")

def _put_entries(
def _process_entries(
self, context: RequestContext, entries: PutEventsRequestEntryList
) -> tuple[list, list]:
entries_uuids = []
processed_entries_uuids = []
failed_entries = []
for event in entries:
event_bus_name = event.get("EventBusName", "default")
event = format_event(event, context.region, context.account_id)
entries_uuids.append(event["id"])
processed_entries_uuids.append(event["id"])
store = self.get_store(context)
try:
event_bus = self.get_event_bus(event_bus_name, store)
Expand All @@ -667,4 +667,4 @@ def _put_entries(
"ErrorMessage": str(error),
}
)
return entries_uuids, failed_entries
return processed_entries_uuids, failed_entries

0 comments on commit da0f12a

Please sign in to comment.