'Runs a flow on the client, and waits for it to finish.'

def _RunAndWaitForVFSFileUpdate(self, path):

    client_id = rdf_client.GetClientURNFromPath(path)
    if (client_id is None):
        return
    flow_utils.UpdateVFSFileAndWait(client_id, token=self.token, vfs_file_urn=self.root.Add(path), timeout=self.timeout)
