DataIntegrityClient

This is the Data Integrity Client which allows the simple reporting of problematic file and replicas to the IntegrityDB and their status correctly updated in the FileCatalog.

class DIRAC.DataManagementSystem.Client.DataIntegrityClient.DataIntegrityClient(**kwargs)

Bases: DIRAC.Core.Base.Client.Client

Client exposing the DataIntegrity Service.

__init__(**kwargs)

C’tor.

Parameters

kwargs – just stored as an attribute and passed when creating the RPCClient

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

getClientKWArgs()

Returns a copy of the connection arguments

getServer()

Getter for the server url. Useful ?

httpsClient

alias of DIRAC.Core.Tornado.Client.TornadoClient.TornadoClient

reportProblematicReplicas(replicaTuple, se, reason)

Simple wrapper function around setReplicaProblematic

resolveCatalogPFNSizeMismatch(problematicDict)

This takes the problematic dictionary returned by the integrity DB and resolved the CatalogPFNSizeMismatch prognosis

setFileProblematic(lfn, reason, sourceComponent='')

This method updates the status of the file in the FileCatalog and the IntegrityDB

lfn - the lfn of the file reason - this is given to the integrity DB and should reflect the problem observed with the file

sourceComponent is the component issuing the request.

setReplicaProblematic(replicaTuple, sourceComponent='')

This method updates the status of the replica in the FileCatalog and the IntegrityDB The supplied replicaDict should be of the form {lfn :{‘PFN’:pfn,’SE’:se,’Prognosis’:prognosis}

lfn - the lfn of the file pfn - the pfn if available (otherwise ‘’) se - the storage element of the problematic replica (otherwise ‘’) prognosis - this is given to the integrity DB and should reflect the problem observed with the file

sourceComponent is the component issuing the request.

setServer(url)

Set the server URL used by default

Parameters

url – url of the service