celery-aio-pool

celery-aio-pool copied to clipboard

Bumps [idna](https://github.com/kjd/idna) from 3.6 to 3.7. Release notes Sourced from idna's releases. v3.7 What's Changed Fix issue where specially crafted inputs to encode() could take exceptionally long amount of time...

dependabot[bot]

Bumps [black](https://github.com/psf/black) from 24.2.0 to 24.3.0. Release notes Sourced from black's releases. 24.3.0 Highlights This release is a milestone: it fixes Black's first CVE security vulnerability. If you run Black...

dependabot[bot]

How send tasks in async

5

Hello! Pool works perfect. But I some stuck with solution how to send tasks. Right now I just sending it in sync manner: ```python celery_app.send_task("sso.tasks.parse_whitelist", kwargs={"company_id": company.id} ``` Any sync/async...

Skorpyon

Add support for "--concurrency".

4

As of #3, and as per https://github.com/celery/celery/issues/7874#issuecomment-1328217302, the code is missing support for `--concurrency`. I know we have not had the assistance/input/review we would have liked on the basic design,...

ShaheedHaque

Long running tasks blocking Kombu heartbeats

1

Hello, @the-wondersmith ! I found some issue in your pool (and in celery-pool-asyncio it is same): Long running tasks blocked pool (?) and Kombu don't sending AMQP heartbeats till task...

Skorpyon

Signals support

1

Hello, is there a way to make async Celery Signals? Do you have an Idea of a workaround? what I want to achieve is the async initialization of some resources...

mister-vio

When using `PYTHONOPTIMIZE` (https://docs.python.org/3/using/cmdline.html#cmdoption-O) assert statements will be removed. In that case, `patch_celery_tracer` will not be called: https://github.com/the-wondersmith/celery-aio-pool/blob/890a7b6c03d9060fdb4cd4ce5f52ea5c7f4954f3/celery_aio_pool/pool.py#L79 The issue could be fixed by replacing the assert statement by an...

tristandb

Auto retry on exception feature of celery not working

2

* Celery Executor version: 5.2.7 * Python version: 3.11.2 * Operating System: python:3.11-slim (debian) ### Description Trying to use the auto retry on exception feature of celery tasks. I've tried...

jgz