Skip to content

Commit

Permalink
Addressing PR comments
Browse files Browse the repository at this point in the history
  • Loading branch information
dliappis committed May 2, 2018
1 parent 284e3fa commit 0a17876
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions esrally/driver/driver.py
Original file line number Diff line number Diff line change
Expand Up @@ -582,7 +582,7 @@ def __init__(self):

@actor.no_retry("load generator")
def receiveMsg_StartLoadGenerator(self, msg, sender):
def EsClients(all_hosts, all_client_options):
def es_clients(all_hosts, all_client_options):
es = {}
for cluster_name, cluster_hosts in all_hosts.items():
es[cluster_name] = client.EsClientFactory(cluster_hosts, all_client_options[cluster_name]).create()
Expand All @@ -593,7 +593,7 @@ def EsClients(all_hosts, all_client_options):
self.client_id = msg.client_id
self.config = load_local_config(msg.config)
self.abort_on_error = self.config.opts("driver", "on.error") == "abort"
self.es = EsClients(self.config.opts("client", "hosts").all_hosts, self.config.opts("client", "options").all_client_options)
self.es = es_clients(self.config.opts("client", "hosts").all_hosts, self.config.opts("client", "options").all_client_options)
self.track = msg.track
track.set_absolute_data_path(self.config, self.track)
self.tasks = msg.tasks
Expand Down
4 changes: 2 additions & 2 deletions esrally/racecontrol.py
Original file line number Diff line number Diff line change
Expand Up @@ -289,9 +289,9 @@ def race(cfg, sources=False, build=False, distribution=False, external=False, do
def set_default_hosts(cfg, host="127.0.0.1", port=9200):
configured_hosts = cfg.opts("client", "hosts")
if len(configured_hosts.default) !=0 :
logger.info("Using configured hosts {}".format(configured_hosts.default))
logger.info("Using configured hosts %s", configured_hosts.default)
else:
logger.info("Setting default host to [{}:{}]".format(host, port))
logger.info("Setting default host to [%s:%d]", (host, port))
default_host_object = opts.TargetHosts("{}:{}".format(host,port))
cfg.add(config.Scope.benchmark, "client", "hosts", default_host_object)

Expand Down

0 comments on commit 0a17876

Please sign in to comment.