MoveReplica
MoveReplica operation handler
This handler moves replicas from source SEs to target SEs. Replicas are first replicated to target SEs and then removed from the source SEs
- class DIRAC.DataManagementSystem.Agent.RequestOperations.MoveReplica.MoveReplica(operation=None, csPath=None)
Bases:
DMSRequestOperationsBase
- class MoveReplica
MoveReplica operation handler
- __init__(operation=None, csPath=None)
c’tor
- bulkRemoval(toRemoveDict, targetSE)
remove replicas :toRemoveDict: at :targetSE:
- checkSEsRSS(checkSEs=None, access='WriteAccess', failIfBanned=True)
check SEs. By default, we check the SEs for WriteAccess, but it is configurable
- createRMSRecord(status, nbObject)
This method is used to create a record given some parameters for sending it to the ES backend. It is used inside DMS/Agent/RequestOperations and this method is designed particularly for file type of objects.
- Parameters:
status – This can be one of these i.e. Attempted, Failed, or Successful.
nbObject – This is number of objects in question.
- Returns:
a dictionary.
- dmRemoval(toRemoveDict, targetSEs)
- dmTransfer(opFile)
replicate and register using dataManager
- getProxyForLFN(lfn)
get proxy for lfn
- Parameters:
lfn (str) – LFN
- Returns:
S_ERROR or S_OK( “/path/to/proxy/file” )
- getRegisterOperation(opFile, targetSE, type='RegisterFile', catalog=None)
add RegisterReplica operation for file
- getWaitingFilesList()
prepare waiting files list, update Attempt, filter out MaxAttempt
- makeProperty(name, value, readOnly=False)
Add property :name: to class
This also creates a private :_name: attribute If you want to make read only property, set :readOnly: flag to True :warn: could raise AttributeError if :name: of :_name: is already defined as an attribute
- classmethod rssClient()
ResourceStatusClient getter
- rssSEStatus(se, status, retries=2)
check SE :se: for status :status:
- setOperation(operation)
operation and request setter
- property shifter