TransformationManagerHandler

DISET request handler base class for the TransformationDB.

class DIRAC.TransformationSystem.Service.TransformationManagerHandler.TransformationManagerHandler(handlerInitDict, trid)

Bases: DIRAC.Core.DISET.RequestHandler.RequestHandler

__init__(handlerInitDict, trid)

Constructor

Parameters

• handlerInitDict (dictionary) – Information vars for the service

• trid (object) – Transport to use

auth_ping = ['all']

auth_refreshConfiguration = ['CSAdministrator']

auth_whoami = ['all']

classmethod export_addDirectory(path, force=False)

classmethod export_addFile(fileDicts, force=False)

Interface provides { LFN1 : { PFN1, SE1, … }, LFN2 : { PFN2, SE2, … } }

classmethod export_addFilesToTransformation(transName, lfns)

classmethod export_addTaskForTransformation(transName, lfns=[], se='Unknown')

export_addTransformation(transName, description, longDescription, transType, plugin, agentType, fileMask, transformationGroup='General', groupSize=1, inheritedFrom=0, body='', maxTasks=0, eventsPerTask=0, addFiles=True, inputMetaQuery=None, outputMetaQuery=None)

export_cleanTransformation(transName)

export_createTransformationMetaQuery(transName, queryDict, queryType)

export_deleteTasks(transName, taskMin, taskMax)

export_deleteTransformation(transName)

export_deleteTransformationMetaQuery(transName, queryType)

classmethod export_deleteTransformationParameter(transName, paramName)

static export_echo(data)

This method is used for testing performance of the service

Parameters

data (str) – data to be sent back to the caller

Returns

S_OK, Value is the input data

classmethod export_exists(lfns)

export_extendTransformation(transName, nTasks)

export_getAdditionalParameters(transName)

classmethod export_getCounters(table, attrList, condDict, older=None, newer=None, timeStamp=None)

classmethod export_getDistinctAttributeValues(attribute, selectDict)

classmethod export_getFileSummary(lfns)

export_getTabbedSummaryWeb(table, requestedTables, selectDict, sortList, startItem, maxItems)

classmethod export_getTableDistinctAttributeValues(table, attributes, selectDict)

export_getTasksToSubmit(transName, numTasks, site='')

Get information necessary for submission for a given number of tasks for a given transformation

classmethod export_getTransformation(transName, extraParams=False)

classmethod export_getTransformationFiles(condDict=None, older=None, newer=None, timeStamp='LastUpdate', orderAttribute=None, limit=None, offset=None)

classmethod export_getTransformationFilesCount(transName, field, selection={})

export_getTransformationFilesSummaryWeb(selectDict, sortList, startItem, maxItems)

export_getTransformationLogging(transName)

export_getTransformationMetaQuery(transName, queryType)

classmethod export_getTransformationParameters(transName, parameters)

classmethod export_getTransformationStats(transName)

classmethod export_getTransformationStatusCounters()

export_getTransformationSummary()

Get the summary of the currently existing transformations

export_getTransformationSummaryWeb(selectDict, sortList, startItem, maxItems)

Get the summary of the transformation information for a given page in the generic format

classmethod export_getTransformationTaskStats(transName)

classmethod export_getTransformationTasks(condDict=None, older=None, newer=None, timeStamp='CreationTime', orderAttribute=None, limit=None, inputVector=False, offset=None)

export_getTransformationTasksSummaryWeb(selectDict, sortList, startItem, maxItems)

classmethod export_getTransformationWithStatus(status)

classmethod export_getTransformations(condDict=None, older=None, newer=None, timeStamp='CreationDate', orderAttribute=None, limit=None, extraParams=False, offset=None, columns=None)

export_getTransformationsSummaryWeb(selectDict, sortList, startItem, maxItems)

export_ping()

static export_refreshConfiguration(fromMaster)

Force refreshing the configuration data

Parameters

fromMaster (bool) – flag to refresh from the master configuration service

classmethod export_removeFile(lfns)

Interface provides [ LFN1, LFN2, … ]

classmethod export_setFileStatusForTransformation(transName, dictOfNewFilesStatus)

Sets the file status for the transformation.

The dictOfNewFilesStatus is a dictionary with the form: {12345: (‘StatusA’, errorA), 6789: (‘StatusB’,errorB), … } where the keys are fileIDs The tuple may be a string with only the status if the client was from an older version

classmethod export_setMetadata(path, querydict)

Set metadata to a file or to a directory (path)

classmethod export_setTaskStatus(transName, taskID, status)

classmethod export_setTaskStatusAndWmsID(transName, taskID, status, taskWmsID)

export_setTransformationParameter(transName, paramName, paramValue)

export_whoami()

A simple whoami, returns all credential dictionary, except certificate chain object.

classmethod getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns

Value for serviceSection/optionName in the CS being defaultValue the default

getRemoteAddress()

Get the address of the remote peer.

Returns

Address of remote peer.

getRemoteCredentials()

Get the credentials of the remote peer.

Returns

Credentials dictionary of remote peer.

initialize()

Initialize this instance of the handler (to be overwritten)

classmethod initializeHandler(serviceInfoDict)

Initialization of DB object

srv_disconnect(trid=None)

classmethod srv_disconnectClient(trid)

srv_getActionTuple()

classmethod srv_getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns

Value for serviceSection/optionName in the CS being defaultValue the default

srv_getClientSetup()

srv_getClientVO()

srv_getClientVersion()

srv_getFormattedRemoteCredentials()

classmethod srv_getMonitor()

srv_getRemoteAddress()

Get the address of the remote peer.

Returns

Address of remote peer.

srv_getRemoteCredentials()

Get the credentials of the remote peer.

Returns

Credentials dictionary of remote peer.

classmethod srv_getServiceName()

srv_getTransportID()

classmethod srv_getURL()

classmethod srv_msgCreate(msgName)

srv_msgReply(msgObj)

classmethod srv_msgSend(trid, msgObj)

transfer_bulkFromClient(bulkId, token, bulkSize, fileHelper)

transfer_bulkToClient(bulkId, token, fileHelper)

transfer_fromClient(fileId, token, fileSize, fileHelper)

transfer_listBulk(bulkId, token, fileHelper)

transfer_toClient(fileId, token, fileHelper)

types_addDirectory = [(<class 'str'>,)]

types_addFile = [[<class 'list'>, <class 'dict'>, (<class 'str'>,)]]

types_addFilesToTransformation = [[<class 'str'>, <class 'int'>], [<class 'list'>, <class 'tuple'>]]

types_addTaskForTransformation = [[<class 'str'>, <class 'int'>]]

types_addTransformation = [(<class 'str'>,), (<class 'str'>,), (<class 'str'>,), (<class 'str'>,), (<class 'str'>,), (<class 'str'>,), (<class 'str'>,)]

types_cleanTransformation = [[<class 'str'>, <class 'int'>]]

types_createTransformationMetaQuery = [[<class 'str'>, <class 'int'>], <class 'dict'>, (<class 'str'>,)]

types_deleteTasks = [[<class 'str'>, <class 'int'>], [<class 'int'>], [<class 'int'>]]

types_deleteTransformation = [[<class 'str'>, <class 'int'>]]

types_deleteTransformationMetaQuery = [[<class 'str'>, <class 'int'>], (<class 'str'>,)]

types_deleteTransformationParameter = [[<class 'str'>, <class 'int'>], (<class 'str'>,)]

types_echo = [(<class 'str'>,)]

types_exists = [<class 'list'>]

types_extendTransformation = [[<class 'str'>, <class 'int'>], [<class 'int'>]]

types_getAdditionalParameters = [[<class 'str'>, <class 'int'>]]

types_getCounters = [(<class 'str'>,), <class 'list'>, <class 'dict'>]

types_getDistinctAttributeValues = [(<class 'str'>,), <class 'dict'>]

types_getFileSummary = [<class 'list'>]

types_getTabbedSummaryWeb = [(<class 'str'>,), <class 'dict'>, <class 'dict'>, <class 'list'>, <class 'int'>, <class 'int'>]

types_getTableDistinctAttributeValues = [(<class 'str'>,), <class 'list'>, <class 'dict'>]

types_getTasksToSubmit = [[<class 'str'>, <class 'int'>], [<class 'int'>]]

types_getTransformation = [[<class 'str'>, <class 'int'>]]

types_getTransformationFiles = []

types_getTransformationFilesCount = [[<class 'str'>, <class 'int'>], (<class 'str'>,)]

types_getTransformationFilesSummaryWeb = [<class 'dict'>, <class 'list'>, <class 'int'>, <class 'int'>]

types_getTransformationLogging = [[<class 'str'>, <class 'int'>]]

types_getTransformationMetaQuery = [[<class 'str'>, <class 'int'>], (<class 'str'>,)]

types_getTransformationParameters = [[<class 'str'>, <class 'int'>], [(<class 'str'>,), <class 'list'>]]

types_getTransformationStats = [[<class 'str'>, <class 'int'>]]

types_getTransformationStatusCounters = []

types_getTransformationSummary = []

types_getTransformationSummaryWeb = [<class 'dict'>, <class 'list'>, <class 'int'>, <class 'int'>]

types_getTransformationTaskStats = [[<class 'str'>, <class 'int'>]]

types_getTransformationTasks = []

types_getTransformationTasksSummaryWeb = [<class 'dict'>, <class 'list'>, <class 'int'>, <class 'int'>]

types_getTransformationWithStatus = [[(<class 'str'>,), <class 'list'>, <class 'tuple'>]]

types_getTransformations = []

types_getTransformationsSummaryWeb = [<class 'dict'>, <class 'list'>, <class 'int'>, <class 'int'>]

types_ping = []

types_refreshConfiguration = [<class 'bool'>]

types_removeFile = [[<class 'list'>, <class 'dict'>]]

types_setFileStatusForTransformation = [[<class 'str'>, <class 'int'>], <class 'dict'>]

types_setMetadata = [(<class 'str'>,), <class 'dict'>]

types_setTaskStatus = [[<class 'str'>, <class 'int'>], [<class 'list'>, <class 'int'>], (<class 'str'>,)]

types_setTaskStatusAndWmsID = [[<class 'str'>, <class 'int'>], [<class 'int'>], (<class 'str'>,), (<class 'str'>,)]

types_setTransformationParameter = [[<class 'str'>, <class 'int'>], (<class 'str'>,)]

types_whoami = []