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, VO, gridType, pilotStampDict, **kwargs)

Add a new pilot job reference

Automatically created for the service function export_addPilotReferences()

Parameters:

  • pilotRef – pilotRef

  • VO – VO

  • gridType – gridType

  • pilotStampDict – pilotStampDict

property call

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

Type:

Deprecated

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

getPilotInfo(cls, pilotReference, **kwargs)

Get the info about a given pilot job reference

Automatically created for the service function export_getPilotInfo()

Parameters:

pilotReference – pilotReference

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

getPilots(cls, jobID, **kwargs)

Get 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

selectPilots(cls, condDict, **kwargs)

Select pilots given the selection conditions

Automatically created for the service function export_selectPilots()

Parameters:

condDict – condDict

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