def send_messages()

in functions/source/asset-model-converter/sqs.py [0:0]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    def send_messages(self, messages):
        for i in range(0, len(messages), self.batch_size):
            messages_chunk = list(messages)[i:i + self.batch_size]   
            entries = [{'Id': str(idx), 'MessageBody': json.dumps(msg), 'MessageGroupId': 'lifecycle_events'} for idx,msg in enumerate(messages_chunk)] 

            response = self.sqs_client.send_message_batch(
                QueueUrl=self.queue_url,
                Entries=entries
            )

            logger.info(f"Successfully {response}")