SandboxStoreClient¶
Client for the SandboxStore. Will connect to the WorkloadManagement/SandboxStore service.
- class DIRAC.WorkloadManagementSystem.Client.SandboxStoreClient.SandboxStoreClient(rpcClient=None, transferClient=None, smdb=False, **kwargs)¶
Bases:
object
- __init__(rpcClient=None, transferClient=None, smdb=False, **kwargs)¶
Constructor
- Parameters
rpcClient (object) – SandboxStore service client (None by default)
transferClient (object) – client to upload/download sandboxes (None by default)
smdb (object) – SandboxMetadataDB object, or True if SandboxMetadataDB is to be instantiated for direct access or False if no direct access to the SandboxMetadataDB is done (default)
- assignSandboxToJob(jobId, sbLocation, sbType, ownerName='', ownerGroup='', eSetup='')¶
Assign SB to a job
- assignSandboxToPilot(pilotId, sbLocation, sbType, ownerName='', ownerGroup='', eSetup='')¶
Assign SB to a pilot
- assignSandboxesToJob(jobId, sbList, ownerName='', ownerGroup='', eSetup='')¶
Assign SB to a job
- assignSandboxesToPilot(pilotId, sbList, ownerName='', ownerGroup='', eSetup='')¶
Assign SB to a pilot
- downloadSandbox(sbLocation, destinationDir='', inMemory=False, unpack=True)¶
Download a sandbox file and keep it in bundled form
- downloadSandboxForJob(jobId, sbType, destinationPath='', inMemory=False, unpack=True)¶
Download SB for a job
- downloadSandboxForPilot(jobId, sbType, destinationPath='')¶
Download SB for a pilot
- getSandboxesForJob(jobId)¶
Download job sandbox
- getSandboxesForPilot(pilotId)¶
Get SB for a pilot
- unassignJobs(jobIdList)¶
Unassign SB to a job
- unassignPilots(pilotIdIdList)¶
Unassign SB to a pilot
- uploadFilesAsSandbox(fileList, sizeLimit=0, assignTo=None)¶
Send files in the fileList to a Sandbox service for the given jobID. This is the preferable method to upload sandboxes.
- a fileList item can be:
a string, which is an lfn name
a file name (real), that is supposed to be on disk, in the current directory
a fileObject that should be a BytesIO type of object
- Parameters
assignTo (-) – Dict containing { ‘Job:<jobid>’ : ‘<sbType>’, … }
- uploadFilesAsSandboxForJob(fileList, jobId, sbType, sizeLimit=0)¶
Upload SB for a job
- uploadFilesAsSandboxForPilot(fileList, jobId, sbType, sizeLimit=0)¶
Upload SB for a pilot