# Path: pq/api.py



import time
import asyncio
import threading
import greenlet
from pq import api
        if error:
            raise TestError('just a test')
        return ['OK', 2]


@api.job()
def testlocalqueue(self):
    return self.backend.tasks.queues()


class CpuBoundWithAsync(api.Job):
    concurrency = api.CPUBOUND

    def __call__(self, asyncio=False):
        if asyncio:
            return self.asyncio()
        else:
            return self.greenlet_info()

    def greenlet_info(self):
        return greenlet.getcurrent().parent is not None

    async def asyncio(self):
        await asyncio.sleep(1)
        return self.greenlet_info()


class CpuBoundBigLog(api.Job):
    concurrency = api.CPUBOUND


# Path: pq/api.py



# Path: tests/example/jobs/standard.py
import time
import asyncio
import threading
import greenlet
from pq import api

        if error:
            raise TestError('just a test')
        return ['OK', 2]


@api.job()
def testlocalqueue(self):
    return self.backend.tasks.queues()


class CpuBoundWithAsync(api.Job):
    concurrency = api.CPUBOUND

    def __call__(self, asyncio=False):
        if asyncio:
            return self.asyncio()
        else:
            return self.greenlet_info()

    def greenlet_info(self):
        return greenlet.getcurrent().parent is not None

    async def asyncio(self):
        await asyncio.sleep(1)
        return self.greenlet_info()


class CpuBoundBigLog(api.Job):
    concurrency = api.CPUBOUND


    def __call__(self):