old_contents: import os
  import raven
  
  from celery import Celery, Task
  from classtools import reify
  from redis import StrictRedis
  from raven.contrib.celery import register_signal, register_logger_signal
  
  from newparp.model import sm
  from newparp.model.connections import redis_pool
  
  celery = Celery("newparp", include=[
      "newparp.tasks.background",
      "newparp.tasks.matchmaker",
      "newparp.tasks.reaper",
      "newparp.tasks.roulette_matchmaker",
      "newparp.tasks.chat",
  ])
  
  # Sentry exception logging if there is a sentry object.
  if "SENTRY_PRIVATE_DSN" in os.environ:
      sentry = raven.Client(
          dsn=os.environ["SENTRY_PRIVATE_DSN"],
          include_paths=["newparp"],
      )
      register_logger_signal(sentry)
      register_signal(sentry)
  
  celery.config_from_object('newparp.tasks.config')
  
  class WorkerTask(Task):
      abstract = True
  
      @reify
      def db(self):
          return sm()
  
      @reify
      def redis(self):
          return StrictRedis(connection_pool=redis_pool)
  
      def after_return(self, *args, **kwargs):
          if hasattr(self, "db"):
              self.db.close()
              del self.db
  
          if hasattr(self, "redis"):
              del self.redis
  
new_contents: import os
  import raven
  
  from celery import Celery, Task
  from classtools import reify
  from redis import StrictRedis
  from raven.contrib.celery import register_signal, register_logger_signal
  
  from newparp.model import sm
  from newparp.model.connections import redis_pool
  
  celery = Celery("newparp", include=[
      "newparp.tasks.background",
      "newparp.tasks.matchmaker",
      "newparp.tasks.reaper",
      "newparp.tasks.roulette_matchmaker",
      "newparp.tasks.chat",
      "newparp.tasks.test",
  ])
  
  # Sentry exception logging if there is a sentry object.
  if "SENTRY_PRIVATE_DSN" in os.environ:
      sentry = raven.Client(
          dsn=os.environ["SENTRY_PRIVATE_DSN"],
          include_paths=["newparp"],
      )
      register_logger_signal(sentry)
      register_signal(sentry)
  
  celery.config_from_object('newparp.tasks.config')
  
  class WorkerTask(Task):
      abstract = True
  
      @reify
      def db(self):
          return sm()
  
      @reify
      def redis(self):
          return StrictRedis(connection_pool=redis_pool)
  
      def after_return(self, *args, **kwargs):
          if hasattr(self, "db"):
              self.db.close()
              del self.db
  
          if hasattr(self, "redis"):
              del self.redis
  
subject: Add test tasks to the celery includes.