aiojobs

Jobs scheduler for managing background task (asyncio)

607

Python

=======
aiojobs

Job scheduler for managing background tasks (asyncio)

The library gives a controlled way for scheduling background tasks for
asyncio applications.

… code-block:: bash

$ pip3 install aiojobs

… code-block:: python

import asyncio
import aiojobs

async def coro(timeout):
await asyncio.sleep(timeout)

async def main():
scheduler = aiojobs.Scheduler()
for i in range(100):
# spawn jobs
await scheduler.spawn(coro(i/10))

   await asyncio.sleep(5.0)
   # not all scheduled jobs are finished at the moment

   # gracefully close spawned jobs
   await scheduler.close()

asyncio.get_event_loop().run_until_complete(main())

… code-block:: python

from aiohttp import web
from aiojobs.aiohttp import setup, spawn

async def handler(request):
await spawn(request, coro())
return web.Response()

app = web.Application()
app.router.add_get(‘/’, handler)
setup(app)

or just

… code-block:: python

from aiojobs.aiohttp import atomic

@atomic
async def handler(request):
return web.Response()

For more information read documentation: https://aiojobs.readthedocs.io

Feel free to post your questions and ideas here.

We support Stack Overflow <https://stackoverflow.com>_.
Please add python-asyncio or aiohttp tag to your question there.

The aiojobs package is written by Andrew Svetlov.

It’s Apache 2 licensed and freely available.