'Cleanup any Flocker volumes that were created during the tests.'

def _cleanup_flocker(self):

    local_certs_path = FilePath(self.mktemp())
    d = download(reactor=reactor, username='ubuntu', host=self.client_node_ip.encode('ascii'), remote_path=FilePath('/etc/flocker'), local_path=local_certs_path)
    d.addCallback((lambda ignored: connected_cluster(reactor=reactor, control_node=self.control_node_ip.encode('ascii'), certificates_path=local_certs_path, num_agent_nodes=2, hostname_to_public_address={}, username='user1')))
    d.addCallback((lambda cluster: cluster.clean_nodes(remove_foreign_containers=False)))
    return d
