def _RunAndWaitForVFSFileUpdate(self, path):
    """Runs a flow on the client, and waits for it to finish."""

    client_id = rdf_client.GetClientURNFromPath(path)

    # If we're not actually in a directory on a client, no need to run a flow.
    if client_id is None:
      return

    flow_utils.UpdateVFSFileAndWait(
        client_id,
        token=self.token,
        vfs_file_urn=self.root.Add(path),
        timeout=self.timeout)
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 )
Runs a flow on the client, and waits for it to finish.