'Run a command using SSH.
:param Node node: Node to run command on.
:param [str] command_args: List of command line arguments.
:param callable handle_stdout: Function to handle each line of output.
:return: Deferred, firing when complete.'

def run(self, node, command_args, handle_stdout):

    d = run_ssh(self.reactor, self.user, self.cluster.public_address(node.public_address).exploded, command_args, handle_stdout=handle_stdout)
    return d
