RequestTasks

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

Bases: DIRAC.TransformationSystem.Client.TaskManager.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