celery-pool-asyncio 0.1.8

Celery pool to run coroutine tasks

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.8]

• Cleanup tracer, use celery.app.trace namespase where it possible

[0.1.7]

• Refactor monkey, split it
• Move patch_send_task to own function
• Add patch_result_get to await AsyncResult.get

[0.1.6]

• Avoid building trace twice
• Also this small performance optimization fixed AsyncResult.get

[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