# Path: tests/app.py
# CODE_TEST = '''\
# import time
# def task_function(N = 10, lag = 0.1):
#     time.sleep(lag)
#     return N*N
# '''
# PATH = os.path.dirname(__file__)
# def simple_task(self, value=0):
#     def name(cls):
#     def rpc_name(cls):
#     async def setUpClass(cls):
#     def tearDownClass(cls):
#     def queues(cls):
#     def params(cls):
#     def test_registry(self):
#     def test_consumer(self):
#     def test_job_list(self):
#     async def test_simple_task(self):
#     async def test_info(self):
#     async def test_async_job(self):
#     async def test_failure(self):
#     async def test_execute_addition(self):
#     async def test_green_executor(self):
#     async def test_queue_local(self):
#     async def test_no_callback(self):
#     async def test_cpubound_task(self):
#     async def __test_error_cpubound_task(self):
#     async def test_is_in_greenlet(self):
#     async def test_cpu_supports_asyncio(self):
#     async def test_big_log(self):
#     async def test_execute_python_code(self):
#     async def test_execute_python_script(self):
#     async def test_queue_size(self):
#     async def test_lock(self):
#     async def test_queue_from_task(self):
#     async def test_scrape(self):
#     async def test_delay(self):
#     async def test_thread_io(self):
#     async def test_bad_task(self):
#     async def test_retry(self):
#             def __call__(self, _, event, task):
#     async def test_max_concurrency(self):
#     async def test_task_timeout(self):
#     async def test_rpc_job_list(self):
#     async def test_rpc_queue_task(self):
# class TaskQueueBase:
# class TaskQueueApp(TaskQueueBase):
#         class CheckRetry:


import unittest
    import msgpack
from tests import app
"""Tests task execution with MsgPack serialiser"""

try:
except ImportError:
    msgpack = None




@unittest.skipUnless(msgpack, "Requires msgpack library")

# Path: tests/app.py
# CODE_TEST = '''\
# import time
# def task_function(N = 10, lag = 0.1):
#     time.sleep(lag)
#     return N*N
# '''
# PATH = os.path.dirname(__file__)
# def simple_task(self, value=0):
#     def name(cls):
#     def rpc_name(cls):
#     async def setUpClass(cls):
#     def tearDownClass(cls):
#     def queues(cls):
#     def params(cls):
#     def test_registry(self):
#     def test_consumer(self):
#     def test_job_list(self):
#     async def test_simple_task(self):
#     async def test_info(self):
#     async def test_async_job(self):
#     async def test_failure(self):
#     async def test_execute_addition(self):
#     async def test_green_executor(self):
#     async def test_queue_local(self):
#     async def test_no_callback(self):
#     async def test_cpubound_task(self):
#     async def __test_error_cpubound_task(self):
#     async def test_is_in_greenlet(self):
#     async def test_cpu_supports_asyncio(self):
#     async def test_big_log(self):
#     async def test_execute_python_code(self):
#     async def test_execute_python_script(self):
#     async def test_queue_size(self):
#     async def test_lock(self):
#     async def test_queue_from_task(self):
#     async def test_scrape(self):
#     async def test_delay(self):
#     async def test_thread_io(self):
#     async def test_bad_task(self):
#     async def test_retry(self):
#             def __call__(self, _, event, task):
#     async def test_max_concurrency(self):
#     async def test_task_timeout(self):
#     async def test_rpc_job_list(self):
#     async def test_rpc_queue_task(self):
# class TaskQueueBase:
# class TaskQueueApp(TaskQueueBase):
#         class CheckRetry:


# Path: tests/test_msgpack.py
import unittest
    import msgpack
from tests import app

"""Tests task execution with MsgPack serialiser"""

try:
except ImportError:
    msgpack = None




@unittest.skipUnless(msgpack, "Requires msgpack library")

class TestMsgPackQueue(app.TaskQueueApp, unittest.TestCase):