Celery pool to run coroutine tasks
Project description
Celery Pool AsyncIO
- Free software: Apache Software License 2.0
Features
import asyncio
from celery import Celery
app = Celery()
@app.task(
bind=True,
soft_time_limit=None, # temporary unimplemented. You can help me
time_limit=300, # raises futures.TimeoutError on timeout
)
async def my_task(self, *args, **kwargs):
await asyncio.sleep(5)
@app.task
async def my_simple_task(*args, **kwargs):
await asyncio.sleep(5)
Then run celery:
$ celery worker -A hello_async_celery.app -P celery_pool_asyncio:TaskPool
Changelog
##[0.1.3]
- Add changelog
- Append documentation
##[0.1.2]
- Add monkey patcher to make brocker IO operations nonblocking
##[0.1.1]
- Refactor code
- Fix found errors
##[0.1.0]
- Initial commit
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
celery-pool-asyncio-0.1.3.tar.gz
(10.9 kB
view hashes)
Built Distribution
Close
Hashes for celery-pool-asyncio-0.1.3.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 3fc73008ccf0aadb6b1e3031826831cb1407eaedcf8361791736768757d62c05 |
|
MD5 | deef12e512fffa73d6ab60e163abd082 |
|
BLAKE2b-256 | 9864fc9cf4170f571647b9610a69ca8f564886c05598d858e9723f5355ff5fe9 |
Close
Hashes for celery_pool_asyncio-0.1.3-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ef7b918ddf3e206cb5beb09fbc37a8b69889104657c75ad0c01e9984c841b1bf |
|
MD5 | 35d8869713b92393c0bcd5113f5490b7 |
|
BLAKE2b-256 | 0fb9ca7389be715f04bd1c4a75cce35642661645816ae3dc3741b9a7078e2143 |