RequestTasks

class DIRAC.TransformationSystem.Client.RequestTasks.RequestTasks(transClient=None, logger=None, requestClient=None, requestClass=None, requestValidator=None, ownerDN=None, ownerGroup=None)

Bases: TaskBase

Class for handling tasks for the RMS

__init__(transClient=None, logger=None, requestClient=None, requestClass=None, requestValidator=None, ownerDN=None, ownerGroup=None)

c’tor

the requestClass is by default Request. If extensions want to use an extended type, they can pass it as a parameter. This is the same behavior as WorfkloTasks and jobClass

getSubmittedFileStatus(fileDicts)

Check if transformation files changed status, and return a list of taskIDs per new status

getSubmittedTaskStatus(taskDicts)

Check if tasks changed status, and return a list of tasks per new status

prepareTransformationTasks(transBody, taskDict, owner='', ownerGroup='', ownerDN='', bulkSubmissionFlag=False)

Prepare tasks, given a taskDict, that is created (with some manipulation) by the DB

submitTaskToExternal(oRequest)

Submits a request to RMS

submitTasksToExternal(_task)

To make sure the method is implemented in the derived class

submitTransformationTasks(taskDict)

Submit requests one by one

updateDBAfterTaskSubmission(taskDict)

Sets tasks status after the submission to “Submitted”, in case of success

updateTransformationReservedTasks(taskDicts)

To make sure the method is implemented in the derived class

exception DIRAC.TransformationSystem.Client.RequestTasks.StopTaskIteration

Bases: Exception

Utility Exception to stop creating a Request for the current worked on task

__init__(*args, **kwargs)

add_note()

Exception.add_note(note) – add a note to the exception

args

with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.