# Path: kale/exceptions.py
# class ImproperlyConfiguredException(Exception):
# class TaskException(Exception):
# class ChubbyTaskException(TaskException):
# class TimeoutException(TaskException):
# class InvalidTimeLimitTaskException(TaskException):
# class InvalidTaskDelayException(TaskException):
# class BlacklistedException(TaskException):
# class QueueException(Exception):
# class SendMessagesException(QueueException):
# class DeleteMessagesException(QueueException):
# class ChangeMessagesVisibilityException(QueueException):
#     def __init__(self, msg_count):
#     def __init__(self, msg_count):
#     def __init__(self, msg_count):
# 
# Path: kale/sqs.py
# class SQSTalk(object):
#     def __init__(self, *args, **kwargs):
#     def _get_or_create_queue(self, queue_name):
#     def get_all_queues(self, prefix=''):
#     def _get_sqs_queue_tags(self, queue_name):


import unittest
import boto3
import mock
from moto import mock_sqs
from kale import exceptions
from kale import sqs

        expected_hi_dlq_queue = sqs_inst._sqs.Queue('https://queue.amazonaws.com/123456789012/'
                                                'HighPriorityTest2-dlq')


        self.assertEqual(len(sqs_inst._queues), 3)

        self.assertEqual(expected_low_queue, sqs_inst._queues['LowPriorityTest1'])
        self.assertEqual(expected_hi_queue, sqs_inst._queues['HighPriorityTest2'])

    def test_get_queues(self):
        boto3.setup_default_session()
        sqs_inst = sqs.SQSTalk()

        sqs_inst._get_or_create_queue('LowPriorityTest3')
        sqs_inst._get_or_create_queue('HighPriorityTest4')

        queues = sqs_inst.get_all_queues()
        print(queues)
        self.assertEqual(len(queues), 2)

        queues = sqs_inst.get_all_queues('Low')
        self.assertEqual(len(queues), 1)

        sqs_inst.get_all_queues('High')
        self.assertEqual(len(queues), 1)

    def test_get_improperly_configured(self):
        with mock.patch('kale.sqs.settings') as mock_settings:
            mock_settings.PROPERLY_CONFIGURED = False

# Path: kale/exceptions.py
# class ImproperlyConfiguredException(Exception):
# class TaskException(Exception):
# class ChubbyTaskException(TaskException):
# class TimeoutException(TaskException):
# class InvalidTimeLimitTaskException(TaskException):
# class InvalidTaskDelayException(TaskException):
# class BlacklistedException(TaskException):
# class QueueException(Exception):
# class SendMessagesException(QueueException):
# class DeleteMessagesException(QueueException):
# class ChangeMessagesVisibilityException(QueueException):
#     def __init__(self, msg_count):
#     def __init__(self, msg_count):
#     def __init__(self, msg_count):
# 
# Path: kale/sqs.py
# class SQSTalk(object):
#     def __init__(self, *args, **kwargs):
#     def _get_or_create_queue(self, queue_name):
#     def get_all_queues(self, prefix=''):
#     def _get_sqs_queue_tags(self, queue_name):


# Path: kale/tests/test_sqs.py
import unittest
import boto3
import mock
from moto import mock_sqs
from kale import exceptions
from kale import sqs


        expected_hi_dlq_queue = sqs_inst._sqs.Queue('https://queue.amazonaws.com/123456789012/'
                                                'HighPriorityTest2-dlq')


        self.assertEqual(len(sqs_inst._queues), 3)

        self.assertEqual(expected_low_queue, sqs_inst._queues['LowPriorityTest1'])
        self.assertEqual(expected_hi_queue, sqs_inst._queues['HighPriorityTest2'])

    def test_get_queues(self):
        boto3.setup_default_session()
        sqs_inst = sqs.SQSTalk()

        sqs_inst._get_or_create_queue('LowPriorityTest3')
        sqs_inst._get_or_create_queue('HighPriorityTest4')

        queues = sqs_inst.get_all_queues()
        print(queues)
        self.assertEqual(len(queues), 2)

        queues = sqs_inst.get_all_queues('Low')
        self.assertEqual(len(queues), 1)

        sqs_inst.get_all_queues('High')
        self.assertEqual(len(queues), 1)

    def test_get_improperly_configured(self):
        with mock.patch('kale.sqs.settings') as mock_settings:
            mock_settings.PROPERLY_CONFIGURED = False

            with self.assertRaises(exceptions.ImproperlyConfiguredException):