FTSRequest

..mod: FTSRequest

Helper class to perform FTS job submission and monitoring.

class DIRAC.DataManagementSystem.Client.FTSRequest.FTSRequest

Bases: object

class FTSRequest

Helper class for FTS job submission and monitoring.

__init__()

c’tor

Parameters:self – self reference
dump()

print FTS job parameters and files to stdout

Parameters:self – self reference
dumpSummary(printOutput=False)

get FTS job summary as str

Parameters:
  • self – self reference
  • printOutput (bool) – print summary to stdout
finalize()

finalize FTS job

Parameters:self – self reference
getDone()

get list of succesfully transferred LFNs

Parameters:self – self reference
getFailReason(lfn)

get fail reason for file :lfn:

Parameters:
  • self – self reference
  • lfn (str) – LFN
getFailed()

get list of wrongly transferred LFNs

Parameters:self – self reference
getFailedRegistrations()

get failed registrations dict

Parameters:self – self reference
getRetries(lfn)

get number of attepmts made to transfer file :lfn:

Parameters:
  • self – self reference
  • lfn (str) – LFN
getSourceSURL(lfn)

get source SURL for LFN :lfn:

Parameters:
  • self – self reference
  • lfn (str) – LFN
getStaging()

get files set for prestaging

getTransferStatistics()

collect information of Transfers that can be used by Accounting

Parameters:self – self reference
getTransferTime(lfn)

get duration of transfer for file :lfn:

Parameters:
  • self – self reference
  • lfn (str) – LFN
isRequestTerminal()

check if FTS job has terminated

Parameters:self – self reference
monitor(untilTerminal=False, printOutput=False, full=True)

monitor FTS job

Parameters:
  • self – self reference
  • untilTerminal (bool) – flag to monitor FTS job to its final state
  • printOutput (bool) – flag to print out monitoring information to the stdout
resolveSource()

resolve source SE eligible for submission

Parameters:self – self reference
resolveTarget()

find target SE eligible for submission

Parameters:self – self reference
setCksmTest(cksmTest=False)

set cksm test

Parameters:
  • self – self reference
  • cksmTest (bool) – flag to enable/disable checksum test
setFTSGUID(guid)

FTS job GUID setter

Parameters:
  • self – self reference
  • guid (str) – string containg GUID
setFTSServer(server)

FTS server setter

Parameters:
  • self – self reference
  • server (str) – FTS server URL
setLFN(lfn)

add LFN :lfn: to :fileDict:

Parameters:
  • self – self reference
  • lfn (str) – LFN to add to
setSourceSE(se)

set SE for source

Parameters:
  • self – self reference
  • se (str) – source SE name
setSourceSURL(lfn, surl)

source SURL setter

Parameters:
  • self – self reference
  • lfn (str) – LFN
  • surl (str) – source SURL
setTargetSE(se)

set target SE

Parameters:
  • self – self reference
  • se (str) – target SE name
setTargetSURL(lfn, surl)

set target SURL for LFN :lfn:

Parameters:
  • self – self reference
  • lfn (str) – LFN
  • surl (str) – target SURL
setTargetToken(token)

target space token setter

Parameters:
  • self – self reference
  • token (str) – target space token
submit(monitor=False, printOutput=True)

submit FTS job

Parameters:
  • self – self reference
  • monitor (bool) – flag to monitor progress of FTS job
  • printOutput (bool) – flag to print output of execution to stdout
summary(untilTerminal=False, printOutput=False)

summary of FTS job

Parameters:
  • self – self reference
  • untilTerminal (bool) – flag to monitor FTS job to its final state
  • printOutput (bool) – flag to print out monitoring information to the stdout