def send_message_to_queue()

in src/helper.py [0:0]

• 8 lines of code
• 1 McCabe index (conditional complexity)

def send_message_to_queue(message_body):
    """Sends message to SQS Queue if a time out or limit has occurred to allow for more time for cool down if a
       large number of tasks are being executed in parallel.

    Args:
        message_body (str): ECS Cluster Name

    Returns:
        N/A
    """
    logger.info("Pushing message:%s back on the queue.", message_body)
    sqs = boto3.client('sqs')
    response = sqs.send_message(
        QueueUrl=os.environ['QUEUE_URL'],
        MessageBody=json.dumps(message_body)
    )
    logger.info(response)