def send_batch_messages_to_fifo_queue()

in CommonLayerCode/datalake-library/python/datalake_library/interfaces/sqs_interface.py [0:0]

• 20 lines of code
• 6 McCabe index (conditional complexity)

    def send_batch_messages_to_fifo_queue(self, messages, batch_size, group_id):
        try:
            chunks = [messages[x:x + batch_size] for x in range(0, len(messages), batch_size)]
            for chunk in chunks:
                entries = []
                for x in chunk:
                    entry = {
                        'Id': str(uuid.uuid1()),
                        'MessageBody': str(x),
                        'MessageGroupId': group_id,
                        'MessageDeduplicationId': str(uuid.uuid1())
                    }
                    entries.append(entry)
                self._message_queue.send_messages(Entries=entries)
        except ClientError as e:
            self._logger.error("Received error: %s", e, exc_info=True)
            # If no queue is found pass else raise
            if e.response['Error']['Code'] == 'AWS.SimpleQueueService.NonExistentQueue':
                pass
            else:
                raise e