old_contents: from redis import Redis
  from app import router
  
  
  @router.node(('word',), entry_point=True)
  def emit_words(msg):
      for word in msg.document.strip().split(' '):
          yield word
  
  
  @router.node(('word', 'count'), subscribe_to='tasks.emit_words')
  def tally_word(msg):
      redis = Redis()
      return msg.word, redis.zincrby('celery_emit_example', msg.word, 1)
  
new_contents: from redis import Redis
  from app import router
  
  
  @router.node(('word',), entry_point=True)
  def emit_words(msg):
      for word in msg.document.strip().split(' '):
          yield word
  
  
  @router.node(('word', 'count'), subscribe_to='tasks.emit_words', queue='words')
  def tally_word(msg):
      redis = Redis()
      return msg.word, redis.zincrby('celery_emit_example', msg.word, 1)
  
subject: put tally_word on a separate queue