#NEWLINE# def test_monitor_will_add_new_workers_when_all_workers_are_working( self ) : #NEWLINE# #INDENT# messages = [ createWorkerStatusMessage ( 'tcp://127.0.0.1:1' , 'en-GB' , 'WORKING' , 1 ) . SerializeToString ( ) ] #NEWLINE# self . run_monitor ( messages ) #NEWLINE# expected_messages = [ { #NEWLINE# #INDENT# 'en-GB' : ( + 1 ) , #NEWLINE# #UNINDENT# } ] #NEWLINE# self . assertEqual ( expected_messages , self . scale_workers . scaling_history )