old_contents: """
  sentry.management.commands.cleanup
  ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  
  :copyright: (c) 2012 by the Sentry Team, see AUTHORS for more details.
  :license: BSD, see LICENSE for more details.
  """
  from __future__ import absolute_import, print_function
  
  from django.core.management.base import BaseCommand
  from optparse import make_option
  
  
  class Command(BaseCommand):
      help = 'Deletes a portion of trailing data based on creation date'
  
      option_list = BaseCommand.option_list + (
          make_option('--days', default='30', type=int, help='Numbers of days to truncate on.'),
          make_option('--project', type=int, help='Limit truncation to only entries from project.'),
      )
  
      def handle(self, **options):
          import logging
          from sentry.tasks.cleanup import cleanup, logger
  
          if options['verbosity'] > 1:
              logger.setLevel(logging.DEBUG)
              logger.addHandler(logging.StreamHandler())
  
          cleanup(days=options['days'], project=options['project'])
  
new_contents: """
  sentry.management.commands.cleanup
  ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  
  :copyright: (c) 2012 by the Sentry Team, see AUTHORS for more details.
  :license: BSD, see LICENSE for more details.
  """
  from __future__ import absolute_import, print_function
  
  from django.core.management.base import BaseCommand
  from optparse import make_option
  
  
  class Command(BaseCommand):
      help = 'Deletes a portion of trailing data based on creation date'
  
      option_list = BaseCommand.option_list + (
          make_option('--days', default='30', type=int, help='Numbers of days to truncate on.'),
          make_option('--project', type=int, help='Limit truncation to only entries from project.'),
          make_option('--concurrency', type=int, default=1, help='The number of concurrent workers to run.'),
      )
  
      def handle(self, **options):
          import logging
          from sentry.tasks.cleanup import cleanup, logger
  
          if options['verbosity'] > 1:
              logger.setLevel(logging.DEBUG)
              logger.addHandler(logging.StreamHandler())
  
          cleanup(
              days=options['days'],
              project=options['project'],
              concurrency=options['concurrency'],
          )
  
subject: Add concurrency option to cleanup