Skip to main content

Celery pool to run coroutine tasks

Project description

Celery Pool AsyncIO


  • Free software: Apache Software License 2.0


import asyncio
from celery import Celery

app = Celery()

    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)

async def my_simple_task(*args, **kwargs):
    await asyncio.sleep(5)

Then run celery:

$ celery worker -A -P celery_pool_asyncio:TaskPool



  • Fix graceful shutdown


  • Fix monkey: another function must be patched


  • Add changelog
  • Append documentation


  • Add monkey patcher to make brocker IO operations nonblocking


  • Refactor code
  • Fix found errors


  • Initial commit

Project details

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.5.tar.gz (11.3 kB view hashes)

Uploaded Source

Built Distribution

celery_pool_asyncio-0.1.5-py2.py3-none-any.whl (8.2 kB view hashes)

Uploaded Python 2 Python 3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page