#NEWLINE# def start( self , track , setup , metrics_store ) : #NEWLINE# #INDENT# if self . _servers : #NEWLINE# #INDENT# logger . warn ( 'There are still referenced servers on startup. Did the previous shutdown succeed?' ) #NEWLINE# #UNINDENT# num_nodes = setup . candidate . nodes #NEWLINE# first_http_port = self . cfg . opts ( 'provisioning' , 'node.http.port' ) #NEWLINE# t = telemetry . Telemetry ( self . cfg , metrics_store ) #NEWLINE# c = self . cluster_factory . create ( [ { #NEWLINE# #INDENT# 'host' : 'localhost' , #NEWLINE# 'port' : first_http_port , #NEWLINE# #UNINDENT# } ] , [ self . _start_node ( node , setup , metrics_store ) for node in range ( num_nodes ) ] , metrics_store , t ) #NEWLINE# t . attach_to_cluster ( c ) #NEWLINE# self . setup_index ( c , track , setup ) #NEWLINE# return c