@@ -66,43 +66,13 @@ def run_trace(self, *args):
66
66
67
67
def run_blahp_trace (self , lrms ):
68
68
"""Run condor_ce_trace() against a non-HTCondor backend and verify the cache"""
69
- lrms_cache_prefix = {'pbs' : 'qstat' , 'slurm' : 'slurm' }
70
-
71
69
trace_out , _ = self .run_trace (f'-a osgTestBatchSystem = { lrms .lower ()} ' )
72
70
73
71
try :
74
- backend_jobid = re .search (r'%s_JOBID=(\d+)' % lrms .upper (), trace_out ).group (1 )
72
+ re .search (r'%s_JOBID=(\d+)' % lrms .upper (), trace_out ).group (1 )
75
73
except AttributeError :
76
74
# failed to find backend job ID
77
75
self .fail ('did not run against %s' % lrms .upper ())
78
- cache_file = '/var/tmp/%s_cache_%s/blahp_results_cache' % (lrms_cache_prefix [lrms .lower ()],
79
- core .options .username )
80
- with open (cache_file , 'r' ) as handle :
81
- cache = handle .read ()
82
-
83
- # Verify backend job ID in cache for multiple formats between the different
84
- # versions of the blahp. For blahp-1.18.16.bosco-1.osg32:
85
- #
86
- # 2: [BatchJobId="2"; WorkerNode="fermicloud171.fnal.gov-0"; JobStatus=4; ExitCode= 0; ]\n
87
- #
88
- # For blahp-1.18.25.bosco-1.osg33:
89
- #
90
- # 5347907 "(dp0
91
- # S'BatchJobId'
92
- # p1
93
- # S'""5347907""'
94
- # p2
95
- # sS'WorkerNode'
96
- # p3
97
- # S'""node1358""'
98
- # p4
99
- # sS'JobStatus'
100
- # p5
101
- # S'2'
102
- # p6
103
- # s."
104
- self .assertTrue (re .search (r'BatchJobId[=\s"\'p1S]+%s' % backend_jobid , cache ),
105
- 'Job %s not found in %s blahp cache:\n %s' % (backend_jobid , lrms .upper (), cache ))
106
76
107
77
def test_01_status (self ):
108
78
command = ('condor_ce_status' , '-any' )
0 commit comments