# 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
        sqs.SQSTalk._queues = {}

    def tearDown(self):
        self.mock_sqs.stop()

    def test_create_queue(self):
        boto3.setup_default_session()

        sqs_inst = sqs.SQSTalk()

        sqs_inst._get_or_create_queue('LowPriorityTest1')
        sqs_inst._get_or_create_queue('HighPriorityTest2')
        sqs_inst._get_or_create_queue('HighPriorityTest2-dlq')

        expected_low_queue = sqs_inst._sqs.Queue('https://queue.amazonaws.com/123456789012/'
                                                 'LowPriorityTest1')
        expected_hi_queue = sqs_inst._sqs.Queue('https://queue.amazonaws.com/123456789012/'
                                                'HighPriorityTest2')

        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()

# 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

        sqs.SQSTalk._queues = {}

    def tearDown(self):
        self.mock_sqs.stop()

    def test_create_queue(self):
        boto3.setup_default_session()

        sqs_inst = sqs.SQSTalk()

        sqs_inst._get_or_create_queue('LowPriorityTest1')
        sqs_inst._get_or_create_queue('HighPriorityTest2')
        sqs_inst._get_or_create_queue('HighPriorityTest2-dlq')

        expected_low_queue = sqs_inst._sqs.Queue('https://queue.amazonaws.com/123456789012/'
                                                 'LowPriorityTest1')
        expected_hi_queue = sqs_inst._sqs.Queue('https://queue.amazonaws.com/123456789012/'
                                                'HighPriorityTest2')

        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()