old_contents: import os
  
  from pkg_resources import iter_entry_points
  from kombu import Queue, Exchange
  
  try:
      from waterbutler import settings
  except ImportError:
      settings = {}
  
  config = settings.get('TASKS_CONFIG', {})
  
  
  BROKER_URL = config.get(
      'BROKER_URL',
      'amqp://{}:{}//'.format(
          os.environ.get('RABBITMQ_PORT_5672_TCP_ADDR', ''),
          os.environ.get('RABBITMQ_PORT_5672_TCP_PORT', ''),
      )
  )
  
  WAIT_TIMEOUT = config.get('WAIT_TIMEOUT', 15)
  WAIT_INTERVAL = config.get('WAIT_INTERVAL', 0.5)
  ADHOC_BACKEND_PATH = config.get('ADHOC_BACKEND_PATH', '/tmp')
  
  CELERY_CREATE_MISSING_QUEUES = config.get('CELERY_CREATE_MISSING_QUEUES', False)
  CELERY_DEFAULT_QUEUE = config.get('CELERY_DEFAULT_QUEUE', 'waterbutler')
  CELERY_QUEUES = (
      Queue('waterbutler', Exchange('waterbutler'), routing_key='waterbutler'),
  )
  # CELERY_ALWAYS_EAGER = config.get('CELERY_ALWAYS_EAGER', True)
  CELERY_ALWAYS_EAGER = config.get('CELERY_ALWAYS_EAGER', False)
  # CELERY_RESULT_BACKEND = config.get('CELERY_RESULT_BACKEND', 'redis://')
  CELERY_RESULT_BACKEND = config.get('CELERY_RESULT_BACKEND', None)
  CELERY_DISABLE_RATE_LIMITS = config.get('CELERY_DISABLE_RATE_LIMITS', True)
  CELERY_TASK_RESULT_EXPIRES = config.get('CELERY_TASK_RESULT_EXPIRES', 60)
  CELERY_IMPORTS = [
      entry.module_name
      for entry in iter_entry_points(group='waterbutler.providers.tasks', name=None)
  ]
  CELERY_IMPORTS.extend([
      'waterbutler.tasks.move'
  ])
  
  CELERYD_HIJACK_ROOT_LOGGER = False
  CELERY_EAGER_PROPAGATES_EXCEPTIONS = True
  
new_contents: import os
  
  from pkg_resources import iter_entry_points
  from kombu import Queue, Exchange
  
  try:
      from waterbutler import settings
  except ImportError:
      settings = {}
  
  config = settings.get('TASKS_CONFIG', {})
  
  
  BROKER_URL = config.get(
      'BROKER_URL',
      'amqp://{}:{}//'.format(
          os.environ.get('RABBITMQ_PORT_5672_TCP_ADDR', ''),
          os.environ.get('RABBITMQ_PORT_5672_TCP_PORT', ''),
      )
  )
  
  WAIT_TIMEOUT = config.get('WAIT_TIMEOUT', 15)
  WAIT_INTERVAL = config.get('WAIT_INTERVAL', 0.5)
  ADHOC_BACKEND_PATH = config.get('ADHOC_BACKEND_PATH', '/tmp')
  
  CELERY_CREATE_MISSING_QUEUES = config.get('CELERY_CREATE_MISSING_QUEUES', False)
  CELERY_DEFAULT_QUEUE = config.get('CELERY_DEFAULT_QUEUE', 'waterbutler')
  CELERY_QUEUES = (
      Queue('waterbutler', Exchange('waterbutler'), routing_key='waterbutler'),
  )
  # CELERY_ALWAYS_EAGER = config.get('CELERY_ALWAYS_EAGER', True)
  CELERY_ALWAYS_EAGER = config.get('CELERY_ALWAYS_EAGER', False)
  # CELERY_RESULT_BACKEND = config.get('CELERY_RESULT_BACKEND', 'redis://')
  CELERY_RESULT_BACKEND = config.get('CELERY_RESULT_BACKEND', None)
  CELERY_DISABLE_RATE_LIMITS = config.get('CELERY_DISABLE_RATE_LIMITS', True)
  CELERY_TASK_RESULT_EXPIRES = config.get('CELERY_TASK_RESULT_EXPIRES', 60)
  CELERY_IMPORTS = [
      entry.module_name
      for entry in iter_entry_points(group='waterbutler.providers.tasks', name=None)
  ]
  CELERY_IMPORTS.extend([
      'waterbutler.tasks.move'
  ])
  
  CELERY_ACKS_LATE = True
  CELERYD_HIJACK_ROOT_LOGGER = False
  CELERY_EAGER_PROPAGATES_EXCEPTIONS = True
  
subject: Enable CELREY_ACKS_LATE