celery-aio-pool
celery-aio-pool copied to clipboard
Signals support
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 after the worker pool gets created like this:
from celery import signals
@signals.worker_init.connect
async def worker_init_dispatch(*args, **kwargs):
await print('Do some worker initialization')