ProductionClient

Class that contains client access to the production DB handler.

class DIRAC.ProductionSystem.Client.ProductionClient.ProductionClient(**kwargs)

Bases: DIRAC.Core.Base.Client.Client

Exposes the functionality available in the ProductionSystem/ProductionManagerHandler

__init__(**kwargs)

Simple constructor

addProductionStep(prodStep)

Add a production step and update the production description

Parameters:prodStep (object) – the production step, i.e. a ProductionStep object describing the transformation
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
getListOfBundles(self, **kwargs)

Automatically created for the service function export_getListOfBundles()

getProductionTransformations(prodName, condDict=None, older=None, newer=None, timeStamp=None, orderAttribute=None, limit=10000)
Gets all the production transformations for a production, incrementally.
“limit” here is just used to determine the offset.
Parameters:prodName (str) – the production name
Returns:the list of the transformations associated to the production
getProductions(condDict=None, older=None, newer=None, timeStamp=None, orderAttribute=None, limit=100)

Gets all the productions in the system, incrementally. “limit” here is just used to determine the offset.

getServer()

Getter for the server url. Useful ?

setProductionStatus(prodID, status)

Sets the status of a production

Parameters:
  • prodID (int) – the ProductionID
  • status (str) – the production status to be set to the prodID
setServer(url)

Set the server URL used by default

Parameters:url – url of the service
setTimeout(**kwargs)

Specify the timeout of the call. Forwarded to RPCClient

param int timeout:
 timeout for the RPC calls

Deprecated: Please use self._getRPC(timeout) or self.timeout=<value>