2
2
"""
3
3
tests for HTCondorCEComputingElement module
4
4
"""
5
- from __future__ import absolute_import
6
- from __future__ import division
7
- from __future__ import print_function
8
-
9
5
import pytest
10
6
11
7
from DIRAC .Resources .Computing import HTCondorCEComputingElement as HTCE
@@ -96,8 +92,7 @@ def test_getJobStatusBatchSystem(mocker):
96
92
patchPopen .return_value .communicate .side_effect = [("\n " .join (STATUS_LINES ), "" ), ("\n " .join (HISTORY_LINES ), "" )]
97
93
patchPopen .return_value .returncode = 0
98
94
99
- with patchPopen :
100
- ret = Condor .Condor ().getJobStatus (JobIDList = ["123.0" , "123.1" , "123.2" , "333.3" ])
95
+ ret = Condor .Condor ().getJobStatus (JobIDList = ["123.0" , "123.1" , "123.2" , "333.3" ])
101
96
102
97
expectedResults = {
103
98
"123.0" : "Done" ,
@@ -122,17 +117,16 @@ def test__writeSub(mocker, localSchedd, optionsNotExpected, optionsExpected):
122
117
htce .useLocalSchedd = localSchedd
123
118
subFileMock = mocker .Mock ()
124
119
125
- patchFdopen = mocker .patch (MODNAME + ".os.fdopen" , return_value = subFileMock )
126
- patchMkstemp = mocker .patch (MODNAME + ".tempfile.mkstemp" , return_value = ("os" , "pilotName" ))
127
- patchMkdir = mocker .patch (MODNAME + ".mkDir" )
120
+ mocker .patch (MODNAME + ".os.fdopen" , return_value = subFileMock )
121
+ mocker .patch (MODNAME + ".tempfile.mkstemp" , return_value = ("os" , "pilotName" ))
122
+ mocker .patch (MODNAME + ".mkDir" )
128
123
129
- with patchFdopen , patchMkstemp , patchMkdir :
130
- htce ._HTCondorCEComputingElement__writeSub ("dirac-install" , 42 , "" , 1 ) # pylint: disable=E1101
131
- for option in optionsNotExpected :
132
- # the three [0] are: call_args_list[firstCall][ArgsArgumentsTuple][FirstArgsArgument]
133
- assert option not in subFileMock .write .call_args_list [0 ][0 ][0 ]
134
- for option in optionsExpected :
135
- assert option in subFileMock .write .call_args_list [0 ][0 ][0 ]
124
+ htce ._HTCondorCEComputingElement__writeSub ("dirac-install" , 42 , "" , 1 ) # pylint: disable=E1101
125
+ for option in optionsNotExpected :
126
+ # the three [0] are: call_args_list[firstCall][ArgsArgumentsTuple][FirstArgsArgument]
127
+ assert option not in subFileMock .write .call_args_list [0 ][0 ][0 ]
128
+ for option in optionsExpected :
129
+ assert option in subFileMock .write .call_args_list [0 ][0 ][0 ]
136
130
137
131
138
132
@pytest .mark .parametrize (
@@ -166,13 +160,12 @@ def test_submitJob(setUp, mocker, localSchedd, expected):
166
160
htce .ceName = ceName
167
161
168
162
execMock = mocker .patch (MODNAME + ".executeGridCommand" , return_value = S_OK ((0 , "123.0 - 123.0" )))
169
- writeSubMock = mocker .patch (
163
+ mocker .patch (
170
164
MODNAME + ".HTCondorCEComputingElement._HTCondorCEComputingElement__writeSub" , return_value = "dirac_pilot"
171
165
)
172
- osMock = mocker .patch (MODNAME + ".os" )
166
+ mocker .patch (MODNAME + ".os" )
173
167
174
- with execMock , writeSubMock , osMock :
175
- result = htce .submitJob ("pilot" , "proxy" , 1 )
168
+ result = htce .submitJob ("pilot" , "proxy" , 1 )
176
169
177
170
assert result ["OK" ] is True
178
171
assert " " .join (execMock .call_args_list [0 ][0 ][1 ]) == expected
@@ -199,8 +192,7 @@ def test_killJob(setUp, mocker, jobIDList, jobID, ret, success, local):
199
192
htce ._reset ()
200
193
201
194
commandsMock = mocker .patch (MODNAME + ".commands.getstatusoutput" , return_value = (ret , "" ))
202
- with commandsMock :
203
- ret = htce .killJob (jobIDList = jobIDList )
195
+ ret = htce .killJob (jobIDList = jobIDList )
204
196
205
197
assert ret ["OK" ] == success
206
198
if jobID :
0 commit comments