celery-aio-pool icon indicating copy to clipboard operation
celery-aio-pool copied to clipboard

Signals support

Open mister-vio opened this issue 1 year ago • 1 comments

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')

mister-vio avatar Jul 25 '23 21:07 mister-vio