How about using celeryd_after_setup
or celeryd_init
signal?
Follwing example code from the documentation:
from celery.signals import celeryd_init
@celeryd_init.connect(sender='worker12@example.com')
def configure_worker12(conf=None, **kwargs):
...