Jobs scheduler for managing background task (asyncio).
Project description
Jobs scheduler for managing background task (asyncio)
The library gives controlled way for scheduling background tasks for asyncio applications.
Installation
$ pip3 install aiojobs
Usage example
import asyncio
import aiojobs
async def coro(timeout):
await asyncio.sleep(timeout)
async def main():
scheduler = await aiojobs.create_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())
Integration with aiohttp.web
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
from aiojobs.aiohttp import atomic
@atomic
async def handler(request):
return web.Response()
For more information read documentation: https://aiojobs.readthedocs.io
Communication channels
aio-libs google group: https://groups.google.com/forum/#!forum/aio-libs
Feel free to post your questions and ideas here.
Gitter Chat https://gitter.im/aio-libs/Lobby
We support Stack Overflow. Please add python-asyncio or aiohttp tag to your question there.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
aiojobs-0.3.0.tar.gz
(137.0 kB
view hashes)
Built Distribution
aiojobs-0.3.0-py3-none-any.whl
(10.0 kB
view hashes)