Skip to content

Instantly share code, notes, and snippets.

@alexhayes

alexhayes/celery.py

Last active August 29, 2015 14:22
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save alexhayes/aea5389844ff9b853610 to your computer and use it in GitHub Desktop.
Save alexhayes/aea5389844ff9b853610 to your computer and use it in GitHub Desktop.
Download ZIP
Setup celery logging with worker name in format
Raw
celery.py
from celery.signals import celeryd_init, after_setup_task_logger
app = Celery('myapp')
# ...
# ...
# ...
@celeryd_init.connect
def configure_workers(sender=None, conf=None, **kwargs):
worker = sender
def tasks_setup_logging(**kwargs):
print "tasks_setup_logging", worker
after_setup_task_logger.connect(tasks_setup_logging)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment