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.6]
- Avoid building trace twice
[0.1.5]
- Fix graceful shutdown
[0.1.4]
- Fix monkey: another function must be patched
[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.6.tar.gz
(11.3 kB
view hashes)
Built Distribution
Close
Hashes for celery-pool-asyncio-0.1.6.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8e8b1d1f0148926a0ae814fe8381944cd0016501f831f27584949815e8be719e |
|
MD5 | e84254f893ef04e1fd4fb2f1aa6e3d2d |
|
BLAKE2b-256 | 90b3091b384e292e40cbda2167d402f14e4bd7b4bd0181d4c5929d4f2f9f707e |
Close
Hashes for celery_pool_asyncio-0.1.6-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c0f0ba264337afdc93e1bdfc7a6a3720b930e33d4e6a46351e366006155c8fc2 |
|
MD5 | bec8ac3d3cadf3b3abe29df02a42d89f |
|
BLAKE2b-256 | 8868cc3e3bc3b22c2507f1297cd157a4f876836807650fcb194b6bac586743a3 |