'Refreshes claims on records identified by ids.
Args:
ids: A list of ids provided by ClaimRecords
timeout: The new timeout for these claims.
Raises:
LockError: If the queue is not locked.'

def RefreshClaims(self, ids, timeout='30m'):

    expiration = (rdfvalue.RDFDatetime.Now() + rdfvalue.Duration(timeout))
    with data_store.DB.GetMutationPool(token=self.token) as mutation_pool:
        for subject in ids:
            mutation_pool.Set(subject, self.LOCK_ATTRIBUTE, expiration)
