#NEWLINE# @ fake_tasks ( mock_rpc = True , fake_rpc = False ) #NEWLINE# def get_deploy_message( self , rpc_cast ) : #NEWLINE# #INDENT# task = self . env . launch_deployment ( self . cluster . id ) #NEWLINE# self . assertNotEqual ( consts . TASK_STATUSES . error , task . status ) #NEWLINE# ( args , kwargs ) = rpc_cast . call_args #NEWLINE# return rpc_cast [ 1 ] [ 1 ]