#NEWLINE# def repair_profile( title = 'Repair' , cluster = 'blade_11' , rows = 65000000 , threads = 300 ) : #NEWLINE# #INDENT# config = create_baseline_config ( title ) #NEWLINE# config [ 'cluster' ] = title #NEWLINE# config [ 'operations' ] = [ { #NEWLINE# #INDENT# 'operation' : 'stress' , #NEWLINE# 'command' : 'write n={rows} -rate threads={threads}' . format ( rows = rows , threads = threads ) , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'operation' : 'nodetool' , #NEWLINE# 'command' : 'flush' , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'operation' : 'nodetool' , #NEWLINE# 'command' : 'repair' , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'operation' : 'stress' , #NEWLINE# 'command' : 'read n={rows} -rate threads={threads}' . format ( rows = rows , threads = threads ) , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'operation' : 'stress' , #NEWLINE# 'command' : 'read n={rows} -rate threads={threads}' . format ( rows = rows , threads = threads ) , #NEWLINE# #UNINDENT# } ] #NEWLINE# scheduler = Scheduler ( CSTAR_SERVER ) #NEWLINE# scheduler . schedule ( config )