RequestDB¶
Frontend for ReqDB
- mod
RequestDB
- synopsis
db holding Requests
db holding Request, Operation and File
- class DIRAC.RequestManagementSystem.DB.RequestDB.RequestDB¶
Bases:
object
- class RequestDB¶
db holding requests
- __init__()¶
c’tor
- Parameters
self – self reference
- cancelRequest(requestID)¶
- createTables()¶
create tables
- deleteRequest(requestID)¶
delete request given its ID
- Parameters
requestID (str) – request.RequestID
connection (mixed) – connection to use if any
- getBulkRequests(numberOfRequest=10, assigned=True)¶
read as many requests as requested for execution
- getDBSummary()¶
get db summary
- getDistinctValues(tableName, columnName)¶
For a given table and a given field, return the list of of distinct values in the DB
- getRequest(reqID=0, assigned=True)¶
read request for execution
- Parameters
reqID – request’s ID (default 0) If 0, take a pseudo random one
- getRequestCountersWeb(groupingAttribute, selectDict)¶
For the web portal. Returns a dictionary {value : counts} for a given key. The key can be any field from the RequestTable. or “Type”, which will be interpreted as ‘Operation.Type’
- getRequestFileStatus(requestID, lfnList)¶
get status for files in request given its id
A single status is returned by file, which corresponds to the most representative one. That is:
Failed: if it has failed in any of the operation
Scheduled: if it is Scheduled in any of the operation
Waiting: if the process is ongoing
Done: if everything was executed
- getRequestIDForName(requestName)¶
- read request id for given name
if the name is not unique, an error is returned
- Parameters
requestName – name of the request
- getRequestIDsForJobs(jobIDs)¶
returns request ids for jobs given jobIDs
- Parameters
jobIDs (list) – list of jobIDs
- Returns
S_OK( “Successful” : { jobID1 : Request, jobID2: Request, … } “Failed” : { jobID3: “error message”, … } )
- getRequestIDsList(statusList=None, limit=None, since=None, until=None, getJobID=False)¶
select requests with status in :statusList:
- getRequestInfo(requestID)¶
get request info given Request.RequestID
- getRequestStatus(requestID)¶
get request status for a given request ID
- getRequestSummaryWeb(selectDict, sortList, startItem, maxItems)¶
Returns a list of Request for the web portal
- Parameters
selectDict (dict) – parameter on which to restrain the query {key : Value} key can be any of the Request columns, ‘Type’ (interpreted as Operation.Type) and ‘FromData’ and ‘ToData’ are matched against the LastUpdate field
sortList (list) – [sorting column, ASC/DESC]
startItem (int) – start item (for pagination)
maxItems (int) – max items (for pagination)
- getScheduledRequest(operationID)¶
- peekRequest(requestID)¶
get request (ro), no update on states
- Parameters
requestID – Request.RequestID