celery-pool-asyncio
celery-pool-asyncio copied to clipboard
kai3341
Celery pool to run coroutine tasks
I used latest commit version of celery-pool-asyncio and [email protected] (latest supported). Looks like long running tasks blocking Kombu, it don't sending AMQP heatbeats and RabbitMQ kill the connection. Runtime logs...
* Celery Executor version: 4.4.7 * Python version: 3.8 * Operating System: Ubuntu 18.04 ### Description I use this library and sometimes this error appears, I can't figure it out...
Hello, I am noticing multiple errors when using this plugin with Celery 5. Is there any plans to support it in the future?
**This is NOT ready to be merged.** The eventual goal of this PR is to address #17, #23 and #29. At this time, the bare minimum changes have been applied...
Waiting for total code review by @auvipy
Hello! Thank you for your package. I have some problems if i run many same tasks with storing state of task progress: - I can't use `self.update_state` with `@celery.task(bind=True)`; It...
* Celery Executor version: celery 4.3.0 * Python version: 3.8 * Operating System: Ubuntu 20.04 ### Description Im trying to use group to execute a list of subtasks inside of...
Hello, If I make this signal function: ``` @task_prerun.connect async def task_pre_run(task_id, task, args, **kwargs): print(task_id) ``` when I schedule a job it hangs forever at running this, I have...
* Celery Executor version: celery[redis]==4.3.1 * Python version:Python 3.7 * Operating System:macOS mojave ### Description I want to using this library in [Sanic](https://sanic.readthedocs.io/en/latest/) for asyncio. I used redis result backend...
