#NEWLINE# def execute_clean_step( self , task , step ) : #NEWLINE# #INDENT# 'Execute a clean step asynchronously on the agent.\n\n        :param task: a TaskManager object containing the node\n        :param step: a clean step dictionary to execute\n        :raises: NodeCleaningFailure if the agent does not return a command\n            status\n        :returns: states.CLEANWAIT to signify the step will be completed\n            asynchronously.\n        ' #NEWLINE# return deploy_utils . agent_execute_clean_step ( task , self )