PilotManagerClient

Module that contains client access to the Pilots handler.

class DIRAC.WorkloadManagementSystem.Client.PilotManagerClient.PilotManagerClient(url=None, **kwargs)

Bases: Client

PilotManagerClient sets url for the PilotManagerHandler.

__init__(url=None, **kwargs)

Sets URL for PilotManager handler

Parameters:
  • self – self reference

  • url – url of the PilotManagerHandler

  • kwargs – forwarded to the Base Client class

addPilotReferences(cls, pilotRef, ownerGroup, gridType, pilotStampDict, **kwargs)

Add a new pilot job reference

Automatically created for the service function export_addPilotReferences()

Parameters:
  • pilotRef – pilotRef

  • ownerGroup – ownerGroup

  • gridType – gridType

  • pilotStampDict – pilotStampDict

addPilotTQReference(cls, pilotRef, taskQueueID, ownerDN, ownerGroup, broker, gridType, pilotStampDict, **kwargs)

Add a new pilot job reference

Automatically created for the service function export_addPilotTQReference()

Parameters:
  • pilotRef – pilotRef

  • taskQueueID – taskQueueID

  • ownerDN – ownerDN

  • ownerGroup – ownerGroup

  • broker – broker

  • gridType – gridType

  • pilotStampDict – pilotStampDict

property call

To be removed once we’re sure self.call has been removed

Type:

Deprecated

clearPilots(cls, interval, aborted_interval, **kwargs)

Automatically created for the service function export_clearPilots()

Parameters:
  • interval – interval

  • aborted_interval – aborted_interval

countPilots(cls, condDict, older, newer, timeStamp, **kwargs)

Set the pilot agent status

Automatically created for the service function export_countPilots()

Parameters:
  • condDict – condDict

  • older – older

  • newer – newer

  • timeStamp – timeStamp

deletePilots(cls, pilotIDs, **kwargs)

Automatically created for the service function export_deletePilots()

Parameters:

pilotIDs – pilotIDs

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

getCounters(cls, table, keys, condDict, newer, timeStamp, **kwargs)

Set the pilot agent status

Automatically created for the service function export_getCounters()

Parameters:
  • table – table

  • keys – keys

  • condDict – condDict

  • newer – newer

  • timeStamp – timeStamp

getCurrentPilotCounters(cls, attrDict, **kwargs)

Get pilot counters per Status with attrDict selection. Final statuses are given for the last day.

Automatically created for the service function export_getCurrentPilotCounters()

Parameters:

attrDict – attrDict

getGroupedPilotSummary(cls, selectDict, columnList, **kwargs)

Get pilot summary showing grouped by columns in columnList, all pilot states and pilot efficiencies in a single row.

Parameters:
  • selectDict – additional arguments to SELECT clause

  • columnList – a list of columns to GROUP BY (less status column)

Returns:

a dictionary containing column names and data records

Automatically created for the service function export_getGroupedPilotSummary()

getPilotInfo(cls, pilotReference, **kwargs)

Get the info about a given pilot job reference

Automatically created for the service function export_getPilotInfo()

Parameters:

pilotReference – pilotReference

getPilotLoggingInfo(self, pilotReference, **kwargs)

Get the pilot logging info for the Grid job reference

Automatically created for the service function export_getPilotLoggingInfo()

Parameters:

pilotReference – pilotReference

getPilotMonitorSelectors(cls, **kwargs)

Get all the distinct selector values for the Pilot Monitor web portal page

Automatically created for the service function export_getPilotMonitorSelectors()

getPilotMonitorWeb(cls, selectDict, sortList, startItem, maxItems, **kwargs)

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

Automatically created for the service function export_getPilotMonitorWeb()

Parameters:
  • selectDict – selectDict

  • sortList – sortList

  • startItem – startItem

  • maxItems – maxItems

getPilotOutput(self, pilotReference, **kwargs)

Get the pilot job standard output and standard error files for the Grid job reference

Automatically created for the service function export_getPilotOutput()

Parameters:

pilotReference – pilotReference

getPilotStatistics(cls, attribute, selectDict, **kwargs)

Get pilot statistics distribution per attribute value with a given selection

Automatically created for the service function export_getPilotStatistics()

Parameters:
  • attribute – attribute

  • selectDict – selectDict

getPilotSummary(cls, startdate, enddate, **kwargs)

Get summary of the status of the LCG Pilot Jobs

Automatically created for the service function export_getPilotSummary()

Parameters:
  • startdate – startdate

  • enddate – enddate

getPilotSummaryWeb(cls, selectDict, sortList, startItem, maxItems, **kwargs)

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

Automatically created for the service function export_getPilotSummaryWeb()

Parameters:
  • selectDict – selectDict

  • sortList – sortList

  • startItem – startItem

  • maxItems – maxItems

getPilots(cls, jobID, **kwargs)

Get pilot references and their states for : - those pilots submitted for the TQ where job is sitting - (or) the pilots executing/having executed the Job

Automatically created for the service function export_getPilots()

Parameters:

jobID – jobID

getServer()

Getter for the server url. Useful ?

httpsClient

alias of TornadoClient

killPilot(cls, pilotRefList, **kwargs)

Kill the specified pilots

Automatically created for the service function export_killPilot()

Parameters:

pilotRefList – pilotRefList

selectPilots(cls, condDict, **kwargs)

Select pilots given the selection conditions

Automatically created for the service function export_selectPilots()

Parameters:

condDict – condDict

setAccountingFlag(cls, pilotRef, mark, **kwargs)

Set the pilot AccountingSent flag

Automatically created for the service function export_setAccountingFlag()

Parameters:
  • pilotRef – pilotRef

  • mark – mark

setJobForPilot(cls, jobID, pilotRef, destination, **kwargs)

Report the DIRAC job ID which is executed by the given pilot job

Automatically created for the service function export_setJobForPilot()

Parameters:
  • jobID – jobID

  • pilotRef – pilotRef

  • destination – destination

setPilotBenchmark(cls, pilotRef, mark, **kwargs)

Set the pilot agent benchmark

Automatically created for the service function export_setPilotBenchmark()

Parameters:
  • pilotRef – pilotRef

  • mark – mark

setPilotStatus(cls, pilotRef, status, destination, reason, gridSite, queue, **kwargs)

Set the pilot agent status

Automatically created for the service function export_setPilotStatus()

Parameters:
  • pilotRef – pilotRef

  • status – status

  • destination – destination

  • reason – reason

  • gridSite – gridSite

  • queue – queue

setServer(url)

Set the server URL used by default

Parameters:

url – url of the service

storePilotOutput(cls, pilotReference, output, error, **kwargs)

Store the pilot output and error

Automatically created for the service function export_storePilotOutput()

Parameters:
  • pilotReference – pilotReference

  • output – output

  • error – error