

def __init__(self, tmp_dir='/tmp/riak/test_server', bin_dir=os.path.expanduser('~/.riak/install/riak-0.14.2/bin'), vm_args=None, **options):
    self._lock = threading.Lock()
    self.temp_dir = tmp_dir
    self.bin_dir = bin_dir
    self._prepared = False
    self._started = False
    self.vm_args = self.VM_ARGS_DEFAULTS.copy()
    if (vm_args is not None):
        self.vm_args = deep_merge(self.vm_args, vm_args)
    self.app_config = self.APP_CONFIG_DEFAULTS.copy()
    for (key, value) in options.items():
        if (key in self.app_config):
            self.app_config[key] = deep_merge(self.app_config[key], value)
    ring_dir = os.path.join(self.temp_dir, 'data', 'ring')
    crash_log = os.path.join(self.temp_dir, 'log', 'crash.log')
    self.app_config['riak_core']['ring_state_dir'] = ring_dir
    self.app_config['riak_core']['platform_data_dir'] = self.temp_dir
    self.app_config['lager'] = {
        'crash_log': crash_log,
    }

dataset/ETHPy150Open basho/riak-python-client/riak/test_server.py TestServer.__init__/original