after_setup_task_logger.connect(initialize_logstash)
from celery.signals import after_setup_logger
after_setup_logger.connect(initialize_logstash)
How to send celery all logs to a custom handler . in my case python-logstash handler