old_contents: 'simple celery app'
  from celery import Celery
  from emit import Router
  
  import logging
  
  app = Celery(
      'celery_emit_example',
      broker='redis://'
  )
  app.conf.update(
      CELERY_IMPORTS = ('tasks',)
  )
  
  router = Router(celery_task=app.task, node_modules=['tasks'])
  
  logging.basicConfig(format='%(levelname)s:%(message)s', level=logging.DEBUG)
  
new_contents: 'simple celery app'
  from celery import Celery
  from emit import CeleryRouter
  
  import logging
  
  app = Celery(
      'celery_emit_example',
      broker='redis://'
  )
  app.conf.update(
      CELERY_IMPORTS = ('tasks',)
  )
  
  router = CeleryRouter(celery_task=app.task, node_modules=['tasks'])
  
  logging.basicConfig(format='%(levelname)s:%(message)s', level=logging.DEBUG)
  
subject: update celery example