@@ -134,7 +134,7 @@ def getRepositoryJobs(self, printOutput=False):
134
134
135
135
Example Usage:
136
136
137
- >>> print dirac.getRepositoryJobs()
137
+ >>> print( dirac.getRepositoryJobs() )
138
138
{'OK': True, 'Value': [1,2,3,4]}
139
139
140
140
:return: S_OK,S_ERROR
@@ -152,7 +152,7 @@ def monitorRepository(self, printOutput=False):
152
152
153
153
Example Usage:
154
154
155
- >>> print dirac.monitorRepository()
155
+ >>> print( dirac.monitorRepository() )
156
156
{'OK': True, 'Value': ''}
157
157
158
158
:returns: S_OK,S_ERROR
@@ -179,7 +179,7 @@ def retrieveRepositorySandboxes(self, requestedStates=None, destinationDirectory
179
179
180
180
Example Usage:
181
181
182
- >>> print dirac.retrieveRepositorySandboxes(requestedStates=['Done','Failed'],destinationDirectory='sandboxes')
182
+ >>> print( dirac.retrieveRepositorySandboxes(requestedStates=['Done','Failed'],destinationDirectory='sandboxes') )
183
183
{'OK': True, 'Value': ''}
184
184
185
185
:param requestedStates: List of jobs states to be considered
@@ -214,7 +214,7 @@ def retrieveRepositoryData(self, requestedStates=None, destinationDirectory=""):
214
214
215
215
Example Usage:
216
216
217
- >>> print dirac.retrieveRepositoryData(requestedStates=['Done'],destinationDirectory='outputData')
217
+ >>> print( dirac.retrieveRepositoryData(requestedStates=['Done'],destinationDirectory='outputData') )
218
218
{'OK': True, 'Value': ''}
219
219
220
220
:param requestedStates: List of jobs states to be considered
@@ -245,7 +245,7 @@ def removeRepository(self):
245
245
246
246
Example Usage:
247
247
248
- >>> print dirac.removeRepository()
248
+ >>> print( dirac.removeRepository() )
249
249
{'OK': True, 'Value': ''}
250
250
251
251
:returns: S_OK,S_ERROR
@@ -272,7 +272,7 @@ def resetRepository(self, jobIDs=None):
272
272
273
273
Example Usage:
274
274
275
- >>> print dirac.resetRepository(jobIDs = [1111,2222,'3333'])
275
+ >>> print( dirac.resetRepository(jobIDs = [1111,2222,'3333']) )
276
276
{'OK': True, 'Value': ''}
277
277
278
278
:returns: S_OK,S_ERROR
@@ -304,7 +304,7 @@ def submitJob(self, job, mode="wms"):
304
304
305
305
Example usage:
306
306
307
- >>> print dirac.submitJob(job)
307
+ >>> print( dirac.submitJob(job) )
308
308
{'OK': True, 'Value': '12345'}
309
309
310
310
:param job: Instance of Job class or JDL string
@@ -401,7 +401,7 @@ def getInputDataCatalog(self, lfns, siteName="", fileName="pool_xml_catalog.xml"
401
401
402
402
Example usage:
403
403
404
- >>> print print d. getInputDataCatalog('/lhcb/a/b/c/00001680_00000490_5.dst',None,'myCat.xml')
404
+ >>> print( getInputDataCatalog('/lhcb/a/b/c/00001680_00000490_5.dst',None,'myCat.xml') )
405
405
{'Successful': {'<LFN>': {'pfntype': 'ROOT_All', 'protocol': 'SRM2',
406
406
'pfn': '<PFN>', 'turl': '<TURL>', 'guid': '3E3E097D-0AC0-DB11-9C0A-00188B770645',
407
407
'se': 'CERN-disk'}}, 'Failed': [], 'OK': True, 'Value': ''}
@@ -873,7 +873,7 @@ def getReplicas(self, lfns, active=True, preferDisk=False, diskOnly=False, print
873
873
874
874
Example usage:
875
875
876
- >>> print dirac.getReplicas('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst')
876
+ >>> print( dirac.getReplicas('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst') )
877
877
{'OK': True, 'Value': {'Successful': {'/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst':
878
878
{'CERN-RDST':
879
879
'srm://srm-lhcb.cern.ch/castor/cern.ch/grid/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst'}},
@@ -929,7 +929,7 @@ def getReplicasForJobs(self, lfns, diskOnly=False, printOutput=False):
929
929
930
930
Example usage:
931
931
932
- >>> print dirac.getReplicasForJobs('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst')
932
+ >>> print( dirac.getReplicasForJobs('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst') )
933
933
{'OK': True, 'Value': {'Successful': {'/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst':
934
934
{'CERN-RDST':
935
935
'srm://srm-lhcb.cern.ch/castor/cern.ch/grid/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst'}},
@@ -982,7 +982,7 @@ def getAllReplicas(self, lfns, printOutput=False):
982
982
983
983
Example usage:
984
984
985
- >>> print dirac.getAllReplicas('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst')
985
+ >>> print( dirac.getAllReplicas('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst') )
986
986
{'OK': True, 'Value': {'Successful': {'/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst':
987
987
{'CERN-RDST':
988
988
'srm://srm-lhcb.cern.ch/castor/cern.ch/grid/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst'}},
@@ -1104,7 +1104,7 @@ def getLfnMetadata(self, lfns, printOutput=False):
1104
1104
1105
1105
Example usage:
1106
1106
1107
- >>> print dirac.getLfnMetadata('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst')
1107
+ >>> print( dirac.getLfnMetadata('/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst') )
1108
1108
{'OK': True, 'Value': {'Successful': {'/lhcb/data/CCRC08/RDST/00000106/0000/00000106_00006321_1.rdst':
1109
1109
{'Status': '-', 'Size': 619475828L, 'GUID': 'E871FBA6-71EA-DC11-8F0C-000E0C4DEB4B', 'ChecksumType': 'AD',
1110
1110
'CheckSumValue': ''}}, 'Failed': {}}}
@@ -1158,7 +1158,7 @@ def addFile(self, lfn, fullPath, diracSE, fileGuid=None, printOutput=False):
1158
1158
1159
1159
Example Usage:
1160
1160
1161
- >>> print dirac.addFile('/lhcb/user/p/paterson/myFile.tar.gz','myFile.tar.gz','CERN-USER')
1161
+ >>> print( dirac.addFile('/lhcb/user/p/paterson/myFile.tar.gz','myFile.tar.gz','CERN-USER') )
1162
1162
{'OK': True, 'Value':{'Failed': {},
1163
1163
'Successful': {'/lhcb/user/p/paterson/test/myFile.tar.gz': {'put': 64.246301889419556,
1164
1164
'register': 1.1102778911590576}}}}
@@ -1199,7 +1199,7 @@ def getFile(self, lfn, destDir="", printOutput=False):
1199
1199
1200
1200
Example Usage:
1201
1201
1202
- >>> print dirac.getFile('/lhcb/user/p/paterson/myFile.tar.gz')
1202
+ >>> print( dirac.getFile('/lhcb/user/p/paterson/myFile.tar.gz') )
1203
1203
{'OK': True, 'Value':{'Failed': {},
1204
1204
'Successful': {'/lhcb/user/p/paterson/test/myFile.tar.gz': '/afs/cern.ch/user/p/paterson/myFile.tar.gz'}}}
1205
1205
@@ -1238,7 +1238,7 @@ def replicateFile(self, lfn, destinationSE, sourceSE="", localCache="", printOut
1238
1238
1239
1239
Example Usage:
1240
1240
1241
- >>> print dirac.replicateFile('/lhcb/user/p/paterson/myFile.tar.gz','CNAF-USER')
1241
+ >>> print( dirac.replicateFile('/lhcb/user/p/paterson/myFile.tar.gz','CNAF-USER') )
1242
1242
{'OK': True, 'Value':{'Failed': {},
1243
1243
'Successful': {'/lhcb/user/p/paterson/test/myFile.tar.gz': {'register': 0.44766902923583984,
1244
1244
'replicate': 56.42345404624939}}}}
@@ -1301,7 +1301,7 @@ def replicate(self, lfn, destinationSE, sourceSE="", printOutput=False):
1301
1301
1302
1302
Example Usage:
1303
1303
1304
- >>> print dirac.replicate('/lhcb/user/p/paterson/myFile.tar.gz','CNAF-USER')
1304
+ >>> print( dirac.replicate('/lhcb/user/p/paterson/myFile.tar.gz','CNAF-USER') )
1305
1305
{'OK': True, 'Value':{'Failed': {},
1306
1306
'Successful': {'/lhcb/user/p/paterson/test/myFile.tar.gz': {'register': 0.44766902923583984}}}}
1307
1307
@@ -1341,7 +1341,7 @@ def getAccessURL(self, lfn, storageElement, printOutput=False, protocol=False):
1341
1341
1342
1342
Example Usage:
1343
1343
1344
- >>> print dirac.getAccessURL('/lhcb/data/CCRC08/DST/00000151/0000/00000151_00004848_2.dst','CERN-RAW')
1344
+ >>> print( dirac.getAccessURL('/lhcb/data/CCRC08/DST/00000151/0000/00000151_00004848_2.dst','CERN-RAW') )
1345
1345
{'OK': True, 'Value': {'Successful': {'srm://...': {'SRM2': 'rfio://...'}}, 'Failed': {}}}
1346
1346
1347
1347
:param lfn: Logical File Name (LFN)
@@ -1374,7 +1374,7 @@ def getPhysicalFileAccessURL(self, pfn, storageElement, printOutput=False):
1374
1374
1375
1375
Example Usage:
1376
1376
1377
- >>> print dirac.getPhysicalFileAccessURL('srm://srm-lhcb.cern.ch/castor/cern.ch/grid/lhcb/data/CCRC08/DST/00000151/0000/00000151_00004848_2.dst','CERN_M-DST')
1377
+ >>> print( dirac.getPhysicalFileAccessURL('srm://srm-lhcb.cern.ch/castor/cern.ch/grid/lhcb/data/CCRC08/DST/00000151/0000/00000151_00004848_2.dst','CERN_M-DST') )
1378
1378
{'OK': True, 'Value':{'Failed': {},
1379
1379
'Successful': {'srm://srm-lhcb.cern.ch/castor/cern.ch/grid/lhcb/data/CCRC08/DST/00000151/0000/00000151_00004848_2.dst': {'RFIO': 'castor://...'}}}}
1380
1380
@@ -1406,7 +1406,7 @@ def getPhysicalFileMetadata(self, pfn, storageElement, printOutput=False):
1406
1406
1407
1407
Example Usage:
1408
1408
1409
- >>> print dirac.getPhysicalFileMetadata('srm://srm.grid.sara.nl/pnfs/grid.sara.nl/data
1409
+ >>> print( dirac.getPhysicalFileMetadata('srm://srm.grid.sara.nl/pnfs/grid.sara.nl/data)
1410
1410
/lhcb/data/CCRC08/RAW/LHCb/CCRC/23341/023341_0000039571.raw','NIKHEF-RAW')
1411
1411
{'OK': True, 'Value': {'Successful': {'srm://...': {'SRM2': 'rfio://...'}}, 'Failed': {}}}
1412
1412
@@ -1437,7 +1437,7 @@ def removeFile(self, lfn, printOutput=False):
1437
1437
1438
1438
Example Usage:
1439
1439
1440
- >>> print dirac.removeFile('LFN:/lhcb/data/CCRC08/RAW/LHCb/CCRC/22808/022808_0000018443.raw')
1440
+ >>> print( dirac.removeFile('LFN:/lhcb/data/CCRC08/RAW/LHCb/CCRC/22808/022808_0000018443.raw') )
1441
1441
{'OK': True, 'Value':...}
1442
1442
1443
1443
:param lfn: Logical File Name (LFN)
@@ -1465,7 +1465,7 @@ def removeReplica(self, lfn, storageElement, printOutput=False):
1465
1465
1466
1466
Example Usage:
1467
1467
1468
- >>> print dirac.removeReplica('LFN:/lhcb/user/p/paterson/myDST.dst','CERN-USER')
1468
+ >>> print( dirac.removeReplica('LFN:/lhcb/user/p/paterson/myDST.dst','CERN-USER') )
1469
1469
{'OK': True, 'Value':...}
1470
1470
1471
1471
:param lfn: Logical File Name (LFN)
@@ -1496,7 +1496,7 @@ def getInputSandbox(self, jobID, outputDir=None):
1496
1496
1497
1497
Example Usage:
1498
1498
1499
- >>> print dirac.getInputSandbox(12345)
1499
+ >>> print( dirac.getInputSandbox(12345) )
1500
1500
{'OK': True, 'Value': ['Job__Sandbox__.tar.bz2']}
1501
1501
1502
1502
:param jobID: JobID
@@ -1544,7 +1544,7 @@ def getOutputSandbox(self, jobID, outputDir=None, oversized=True, noJobDir=False
1544
1544
1545
1545
Example Usage:
1546
1546
1547
- >>> print dirac.getOutputSandbox(12345)
1547
+ >>> print( dirac.getOutputSandbox(12345) )
1548
1548
{'OK': True, 'Value': ['Job__Sandbox__.tar.bz2']}
1549
1549
1550
1550
:param jobID: JobID
@@ -1639,7 +1639,7 @@ def deleteJob(self, jobID):
1639
1639
1640
1640
Example Usage:
1641
1641
1642
- >>> print dirac.deleteJob(12345)
1642
+ >>> print( dirac.deleteJob(12345) )
1643
1643
{'OK': True, 'Value': [12345]}
1644
1644
1645
1645
:param jobID: JobID
@@ -1676,7 +1676,7 @@ def rescheduleJob(self, jobID):
1676
1676
1677
1677
Example Usage:
1678
1678
1679
- >>> print dirac.rescheduleJob(12345)
1679
+ >>> print( dirac.rescheduleJob(12345) )
1680
1680
{'OK': True, 'Value': [12345]}
1681
1681
1682
1682
:param jobID: JobID
@@ -1745,7 +1745,7 @@ def getJobStatus(self, jobID):
1745
1745
1746
1746
Example Usage:
1747
1747
1748
- >>> print dirac.getJobStatus(79241)
1748
+ >>> print( dirac.getJobStatus(79241) )
1749
1749
{79241: {'Status': 'Done',
1750
1750
'MinorStatus': 'Execution Complete',
1751
1751
'ApplicationStatus': 'some app status'
@@ -2258,7 +2258,7 @@ def getJobAttributes(self, jobID, printOutput=False):
2258
2258
2259
2259
Example Usage:
2260
2260
2261
- >>> print dirac.getJobAttributes(79241)
2261
+ >>> print( dirac.getJobAttributes(79241) )
2262
2262
{'AccountedFlag': 'False','ApplicationNumStatus': '0',
2263
2263
'ApplicationStatus': 'Job Finished Successfully',
2264
2264
'CPUTime': '0.0','DIRACSetup': 'LHCb-Production'}
@@ -2295,7 +2295,7 @@ def getJobParameters(self, jobID, printOutput=False):
2295
2295
2296
2296
Example Usage:
2297
2297
2298
- >>> print dirac.getJobParameters(79241)
2298
+ >>> print( dirac.getJobParameters(79241) )
2299
2299
{'OK': True, 'Value': {'JobPath': 'JobPath,JobSanity,JobPolicy,InputData,JobScheduling,TaskQueue',
2300
2300
'JobSanityCheck': 'Job: 768 JDL: OK, InputData: 2 LFNs OK, '}
2301
2301
@@ -2334,7 +2334,7 @@ def getJobLoggingInfo(self, jobID, printOutput=False):
2334
2334
2335
2335
Example Usage:
2336
2336
2337
- >>> print dirac.getJobLoggingInfo(79241)
2337
+ >>> print( dirac.getJobLoggingInfo(79241) )
2338
2338
{'OK': True, 'Value': [('Received', 'JobPath', 'Unknown', '2008-01-29 15:37:09', 'JobPathAgent'),
2339
2339
('Checking', 'JobSanity', 'Unknown', '2008-01-29 15:37:14', 'JobSanityAgent')]}
2340
2340
@@ -2377,7 +2377,7 @@ def peekJob(self, jobID, printOutput=False):
2377
2377
2378
2378
Example Usage:
2379
2379
2380
- >>> print dirac.peekJob(1484)
2380
+ >>> print( dirac.peekJob(1484) )
2381
2381
{'OK': True, 'Value': 'Job peek result'}
2382
2382
2383
2383
:param jobID: JobID
@@ -2415,7 +2415,7 @@ def pingService(self, system, service, printOutput=False, url=None):
2415
2415
2416
2416
Example Usage:
2417
2417
2418
- >>> print dirac.pingService('WorkloadManagement','JobManager')
2418
+ >>> print( dirac.pingService('WorkloadManagement','JobManager') )
2419
2419
{'OK': True, 'Value': 'Job ping result'}
2420
2420
2421
2421
:param system: system
@@ -2463,7 +2463,7 @@ def getJobJDL(self, jobID, original=False, printOutput=False):
2463
2463
2464
2464
Example Usage:
2465
2465
2466
- >>> print dirac.getJobJDL(12345)
2466
+ >>> print( dirac.getJobJDL(12345) )
2467
2467
{'Arguments': 'jobDescription.xml',...}
2468
2468
2469
2469
:param jobID: JobID
0 commit comments