# Path: kale/queue_info.py
# class TaskQueue(object):
# class QueueInfoBase(object):
# class QueueInfo(QueueInfoBase):
#     def __init__(self, name='default', priority=5, num_iterations=2,
#                  long_poll_time_sec=5, batch_size=5,
#                  visibility_timeout_sec=600):
#     def _decorate_name(self, name):
#     def get_queues(self):
#     def get_highest_priority_queue_that_needs_work(self):
#     def is_queue_empty(self, queue):
#     def does_queue_need_work(self, queue):
#     def __init__(self, config_file, sqs_talk, queue_cls=TaskQueue):
#     def get_queue(self, simple_name):
#     def get_queues(self):
#     def get_highest_priority_queue_that_needs_work(self):
#     def is_queue_empty(self, queue):
#     def does_queue_need_work(self, queue):
#     def _get_queues_from_config(cls, config_file, queue_cls):
# 
# Path: kale/queue_selector.py
# class SelectQueueBase(object):
# class Random(SelectQueueBase):
# class Lottery(SelectQueueBase):
# class HighestPriorityFirst(SelectQueueBase):
# class HighestPriorityLottery(Lottery):
# class LotteryLottery(Lottery):
# class ReducedLottery(Lottery):
#     def __init__(self, queue_info):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self):
#     def _run_lottery(queues):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):


import unittest
from kale import queue_info
from kale import queue_selector
"""Tests queue_selector.py"""
from __future__ import absolute_import




class MultiQueueInfo(queue_info.QueueInfoBase):
    def get_queues(self):
        return [queue_info.TaskQueue(name='queue1', priority=100),

# Path: kale/queue_info.py
# class TaskQueue(object):
# class QueueInfoBase(object):
# class QueueInfo(QueueInfoBase):
#     def __init__(self, name='default', priority=5, num_iterations=2,
#                  long_poll_time_sec=5, batch_size=5,
#                  visibility_timeout_sec=600):
#     def _decorate_name(self, name):
#     def get_queues(self):
#     def get_highest_priority_queue_that_needs_work(self):
#     def is_queue_empty(self, queue):
#     def does_queue_need_work(self, queue):
#     def __init__(self, config_file, sqs_talk, queue_cls=TaskQueue):
#     def get_queue(self, simple_name):
#     def get_queues(self):
#     def get_highest_priority_queue_that_needs_work(self):
#     def is_queue_empty(self, queue):
#     def does_queue_need_work(self, queue):
#     def _get_queues_from_config(cls, config_file, queue_cls):
# 
# Path: kale/queue_selector.py
# class SelectQueueBase(object):
# class Random(SelectQueueBase):
# class Lottery(SelectQueueBase):
# class HighestPriorityFirst(SelectQueueBase):
# class HighestPriorityLottery(Lottery):
# class LotteryLottery(Lottery):
# class ReducedLottery(Lottery):
#     def __init__(self, queue_info):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self):
#     def _run_lottery(queues):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):
#     def get_queue(self, *args, **kwargs):


# Path: kale/tests/test_queue_selector.py
import unittest
from kale import queue_info
from kale import queue_selector

"""Tests queue_selector.py"""
from __future__ import absolute_import




class MultiQueueInfo(queue_info.QueueInfoBase):
    def get_queues(self):
        return [queue_info.TaskQueue(name='queue1', priority=100),

                queue_info.TaskQueue(name='queue2', priority=50),