#NEWLINE# def test_async_command_success( self ) : #NEWLINE# #INDENT# result = self . extension . execute ( 'fake_async_command' , param = 'v1' ) #NEWLINE# self . assertIsInstance ( result , base . AsyncCommandResult ) #NEWLINE# result . join ( ) #NEWLINE# self . assertEqual ( 'fake_async_command' , result . command_name ) #NEWLINE# self . assertEqual ( { #NEWLINE# #INDENT# 'param' : 'v1' , #NEWLINE# #UNINDENT# } , result . command_params ) #NEWLINE# self . assertEqual ( base . AgentCommandStatus . SUCCEEDED , result . command_status ) #NEWLINE# self . assertIsNone ( result . command_error ) #NEWLINE# self . assertEqual ( { #NEWLINE# #INDENT# 'result' : 'fake_async_command: v1' , #NEWLINE# #UNINDENT# } , result . command_result ) #NEWLINE# self . agent . force_heartbeat . assert_called_once_with ( )