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
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.1.tar.gz
(10.6 kB
view hashes)
Built Distribution
Close
Hashes for celery-pool-asyncio-0.1.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 67774e832701d52c5d8454d120ba8ead32c6d37328dadb3da0a4b81ae90b4173 |
|
MD5 | f040831f90ae3a1b0742d7a9aa7b2887 |
|
BLAKE2b-256 | 873a48ced3133254b80b7c14fb98b06d23e2ceae6b990b055b708c725020bb87 |
Close
Hashes for celery_pool_asyncio-0.1.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e714d2dde542571a20be90a2f2e711faaac0b40918df50d6a90627707b338d25 |
|
MD5 | b3c88b1b073ce59b00b126f8d00c9e06 |
|
BLAKE2b-256 | 3c6e7ae237d787be55b06aefcc070689e0272994c872b51eb6fe7ec9a2580e23 |