#NEWLINE# def RefreshClaims( self , ids , timeout = '30m' ) : #NEWLINE# #INDENT# 'Refreshes claims on records identified by ids.\n\n    Args:\n      ids: A list of ids provided by ClaimRecords\n\n      timeout: The new timeout for these claims.\n\n    Raises:\n      LockError: If the queue is not locked.\n\n    ' #NEWLINE# expiration = ( rdfvalue . RDFDatetime ( ) . Now ( ) + rdfvalue . Duration ( timeout ) ) #NEWLINE# with data_store . DB . GetMutationPool ( token = self . token ) as mutation_pool : #NEWLINE# #INDENT# for subject in ids : #NEWLINE# #INDENT# mutation_pool . Set ( subject , self . LOCK_ATTRIBUTE , expiration )