def flush()

in handlers/aws/replay_trigger.py [0:0]

• 7 lines of code
• 4 McCabe index (conditional complexity)

    def flush(self) -> None:
        for failed_event_uniq_id in self._failed_event_ids:
            del self._events_with_receipt_handle[failed_event_uniq_id]

        for receipt_handle in self._events_with_receipt_handle.values():
            delete_sqs_record(self._replay_queue_arn, receipt_handle)

        if len(self._failed_event_ids) > 0:
            raise ReplayHandlerException()