old_contents: import codecs
  import logging
  import os
  
  with codecs.open(os.path.join(os.path.dirname(__file__), 'VERSION'), "r", "utf-8") as f:
      __version__ = f.readline().rstrip('\n')
  
  logger = logging.getLogger('bqueryd')
  ch = logging.StreamHandler()
  formatter = logging.Formatter('%(levelname)s %(asctime)s %(name)s %(message)s', datefmt="%Y-%m-%d %H:%M:%S")
  ch.setFormatter(formatter)
  logger.addHandler(ch)
  
  DEFAULT_DATA_DIR = '/srv/bcolz/'
  INCOMING = os.path.join(DEFAULT_DATA_DIR, 'incoming')
  if not os.path.exists(INCOMING):
      os.makedirs(INCOMING)
  
  REDIS_SET_KEY = 'bqueryd_controllers'
  REDIS_TICKET_KEY_PREFIX = 'bqueryd_download_ticket_'
  REDIS_DOWNLOAD_LOCK_PREFIX = 'bqueryd_download_lock_'
  REDIS_DOWNLOAD_LOCK_DURATION = 60 * 30  # time in seconds to keep a lock
  
  from rpc import RPC, RPCError
  from controller import ControllerNode
  from worker import WorkerNode, DownloaderNode, MoveBcolzNode
  
new_contents: import codecs
  import logging
  import os
  
  with codecs.open(os.path.join(os.path.dirname(__file__), '..', 'VERSION'), "r", "utf-8") as f:
      __version__ = f.readline().rstrip('\n')
  
  logger = logging.getLogger('bqueryd')
  ch = logging.StreamHandler()
  formatter = logging.Formatter('%(levelname)s %(asctime)s %(name)s %(message)s', datefmt="%Y-%m-%d %H:%M:%S")
  ch.setFormatter(formatter)
  logger.addHandler(ch)
  
  DEFAULT_DATA_DIR = '/srv/bcolz/'
  INCOMING = os.path.join(DEFAULT_DATA_DIR, 'incoming')
  if not os.path.exists(INCOMING):
      os.makedirs(INCOMING)
  
  REDIS_SET_KEY = 'bqueryd_controllers'
  REDIS_TICKET_KEY_PREFIX = 'bqueryd_download_ticket_'
  REDIS_DOWNLOAD_LOCK_PREFIX = 'bqueryd_download_lock_'
  REDIS_DOWNLOAD_LOCK_DURATION = 60 * 30  # time in seconds to keep a lock
  
  from rpc import RPC, RPCError
  from controller import ControllerNode
  from worker import WorkerNode, DownloaderNode, MoveBcolzNode
  
subject: Fix directory location.