FTS3Client
- class DIRAC.DataManagementSystem.Client.FTS3Client.FTS3Client(url=None, **kwargs)
Bases:
ClientClient code to the FTS3 service
- __init__(url=None, **kwargs)
Constructor function.
- property call
To be removed once we’re sure self.call has been removed
- Type:
Deprecated
- executeRPC(*parms, **kws)
This method extracts some parameters from kwargs that are used as parameter of the constructor or RPCClient. Unfortunately, only a few of all the available parameters of BaseClient are exposed.
- Parameters:
rpc – if an RPC client is passed, use that one
timeout – we can change the timeout on a per call bases. Default is self.timeout
url – We can specify which url to use
- getActiveJobs(limit=20, lastMonitor=None, jobAssignmentTag='Assigned', **kwargs)
Get all the FTSJobs that are not in a final state
- Parameters:
limit – max number of jobs to retrieve
- Returns:
list of FTS3Jobs
- getClientKWArgs()
Returns a copy of the connection arguments
- getNonFinishedOperations(limit=20, operationAssignmentTag='Assigned', **kwargs)
Get all the FTS3Operations that have files in New or Failed state (reminder: Failed is NOT terminal for files. Failed is when fts failed, but we can retry)
- Parameters:
limit – max number of jobs to retrieve
- Returns:
json list of FTS3Operation
- getOperation(operationID, **kwargs)
Get the FTS3Operation from the database
- Parameters:
operationID – id of the operation
- Returns:
FTS3Operation object
- getOperationsFromRMSOpID(rmsOpID, **kwargs)
Get the FTS3Operations matching a given RMS Operation
- Parameters:
rmsOpID – id of the operation in the RMS
- Returns:
list of FTS3Operation objects
- getServer()
Getter for the server url. Useful ?
- httpsClient
alias of
TornadoClient
- persistOperation(opObj, **kwargs)
Persist (insert/update) an FTS3Operation object into the db
- Parameters:
opObj – instance of FTS3Operation
- setServer(url)
Set the server URL used by default
- Parameters:
url – url of the service
- updateFileStatus(cls, fileStatusDict, ftsGUID, **kwargs)
Update the file ftsStatus and error
- Parameters:
fileStatusDict – { fileID : { status , error } }
ftsGUID – (not mandatory) If specified, only update the rows where the ftsGUID matches this value.
Automatically created for the service function
export_updateFileStatus()
- updateJobStatus(cls, jobStatusDict, **kwargs)
Update the job Status and error
- Parameters:
jobStatusDict – { jobID : { status , error } }
Automatically created for the service function
export_updateJobStatus()