@@ -250,9 +250,9 @@ def disable_test_option_logging_configuration(self):
250
250
'seed=%s' % TestSearchCommandsApp ._seed ,
251
251
'logging_configuration=logging.conf' ],
252
252
__GETINFO__ = (
253
- os .join ('input' , '_empty.csv' ),
254
- os .join ('output' , 'test_option_logging_configuration.csv' ),
255
- os .join ('log' , 'test_option_logging_configuration.log' )))
253
+ os .path . join ('input' , '_empty.csv' ),
254
+ os .path . join ('output' , 'test_option_logging_configuration.csv' ),
255
+ os .path . join ('log' , 'test_option_logging_configuration.log' )))
256
256
return
257
257
258
258
def disable_test_option_logging_level (self ):
@@ -265,9 +265,9 @@ def disable_test_option_logging_level(self):
265
265
'seed=%s' % TestSearchCommandsApp ._seed ,
266
266
'logging_level=ERROR' ],
267
267
__GETINFO__ = (
268
- os .join ('input' , 'population.csv' ),
269
- os .join ('output' , 'test_option_logging_level.csv' ),
270
- os .join ('log' , 'test_option_logging_level.log' )))
268
+ os .path . join ('input' , 'population.csv' ),
269
+ os .path . join ('output' , 'test_option_logging_level.csv' ),
270
+ os .path . join ('log' , 'test_option_logging_level.log' )))
271
271
return
272
272
273
273
def disable_test_option_show_configuration (self ):
@@ -280,9 +280,9 @@ def disable_test_option_show_configuration(self):
280
280
'seed=%s' % TestSearchCommandsApp ._seed ,
281
281
'show_configuration=true' ],
282
282
__GETINFO__ = (
283
- os .join ('input' , '_empty.csv' ),
284
- os .join ('output' , 'test_option_show_configuration.csv' ),
285
- os .join ('log' , 'test_option_show_configuration.log' )))
283
+ os .path . join ('input' , '_empty.csv' ),
284
+ os .path . join ('output' , 'test_option_show_configuration.csv' ),
285
+ os .path . join ('log' , 'test_option_show_configuration.log' )))
286
286
return
287
287
288
288
def test_generating_command_configuration (self ):
@@ -298,13 +298,13 @@ def test_generating_command_in_isolation(self):
298
298
'rate=200' ,
299
299
'seed=%s' % TestSearchCommandsApp ._seed ],
300
300
__GETINFO__ = (
301
- os .join ('input' , '_empty.csv' ),
302
- os .join ('output' , 'test_generating_command_in_isolation.getinfo.csv' ),
303
- os .join ('log' , 'test_generating_command_in_isolation.log' )),
301
+ os .path . join ('input' , '_empty.csv' ),
302
+ os .path . join ('output' , 'test_generating_command_in_isolation.getinfo.csv' ),
303
+ os .path . join ('log' , 'test_generating_command_in_isolation.log' )),
304
304
__EXECUTE__ = (
305
- os .join ('input' , '_empty.csv' ),
306
- os .join ('output' , 'test_generating_command_in_isolation.execute.csv' ),
307
- os .join ('log' , 'test_generating_command_in_isolation.log' )))
305
+ os .path . join ('input' , '_empty.csv' ),
306
+ os .path . join ('output' , 'test_generating_command_in_isolation.execute.csv' ),
307
+ os .path . join ('log' , 'test_generating_command_in_isolation.log' )))
308
308
self ._assertCorrectOutputFile ('test_generating_command_in_isolation.getinfo.csv' )
309
309
self ._assertCorrectOutputFile ('test_generating_command_in_isolation.execute.csv' )
310
310
return
@@ -326,26 +326,26 @@ def test_reporting_command_in_isolation(self):
326
326
'sum' , [
327
327
'__map__' , 'total=subtotal' , 'count' ],
328
328
__GETINFO__ = (
329
- os .join ('input' , 'counts.csv' ),
330
- os .join ('output' , 'test_reporting_command_in_isolation.map.getinfo.csv' ),
331
- os .join ('log' , 'test_reporting_command_in_isolation.log' )),
329
+ os .path . join ('input' , 'counts.csv' ),
330
+ os .path . join ('output' , 'test_reporting_command_in_isolation.map.getinfo.csv' ),
331
+ os .path . join ('log' , 'test_reporting_command_in_isolation.log' )),
332
332
__EXECUTE__ = (
333
- os .join ('input' , 'counts.csv' ),
334
- os .join ('output' , 'test_reporting_command_in_isolation.map.execute.csv' ),
335
- os .join ('log' , 'test_reporting_command_in_isolation.log' )))
333
+ os .path . join ('input' , 'counts.csv' ),
334
+ os .path . join ('output' , 'test_reporting_command_in_isolation.map.execute.csv' ),
335
+ os .path . join ('log' , 'test_reporting_command_in_isolation.log' )))
336
336
self ._assertCorrectOutputFile ('test_reporting_command_in_isolation.map.getinfo.csv' )
337
337
self ._assertCorrectOutputFile ('test_reporting_command_in_isolation.map.execute.csv' )
338
338
self ._run (
339
339
'sum' , [
340
340
'total=total' , 'count' ],
341
341
__GETINFO__ = (
342
- os .join ('input' , 'subtotals.csv' ),
343
- os .join ('output' , 'test_reporting_command_in_isolation.reduce.getinfo.csv' ),
344
- os .join ('log' , 'test_reporting_command_in_isolation.log' )),
342
+ os .path . join ('input' , 'subtotals.csv' ),
343
+ os .path . join ('output' , 'test_reporting_command_in_isolation.reduce.getinfo.csv' ),
344
+ os .path . join ('log' , 'test_reporting_command_in_isolation.log' )),
345
345
__EXECUTE__ = (
346
- os .join ('input' , 'subtotals.csv' ),
347
- os .join ('output' , 'test_reporting_command_in_isolation.reduce.execute.csv' ),
348
- os .join ('log' , 'test_reporting_command_in_isolation.log' )))
346
+ os .path . join ('input' , 'subtotals.csv' ),
347
+ os .path . join ('output' , 'test_reporting_command_in_isolation.reduce.execute.csv' ),
348
+ os .path . join ('log' , 'test_reporting_command_in_isolation.log' )))
349
349
self ._assertCorrectOutputFile ('test_reporting_command_in_isolation.reduce.getinfo.csv' )
350
350
self ._assertCorrectOutputFile ('test_reporting_command_in_isolation.reduce.execute.csv' )
351
351
return
@@ -367,13 +367,13 @@ def test_streaming_command_in_isolation(self):
367
367
'pattern=\\ w+' ,
368
368
'text' ],
369
369
__GETINFO__ = (
370
- os .join ('input' , 'tweets.csv' ),
371
- os .join ('output' , 'test_streaming_command_in_isolation.getinfo.csv' ),
372
- os .join ('log' , 'test_streaming_command.log' )),
370
+ os .path . join ('input' , 'tweets.csv' ),
371
+ os .path . join ('output' , 'test_streaming_command_in_isolation.getinfo.csv' ),
372
+ os .path . join ('log' , 'test_streaming_command.log' )),
373
373
__EXECUTE__ = (
374
- os .join ('input' , 'tweets.csv' ),
375
- os .join ('output' , 'test_streaming_command_in_isolation.execute.csv' ),
376
- os .join ('log' , 'test_generating_command_in_isolation.log' )))
374
+ os .path . join ('input' , 'tweets.csv' ),
375
+ os .path . join ('output' , 'test_streaming_command_in_isolation.execute.csv' ),
376
+ os .path . join ('log' , 'test_generating_command_in_isolation.log' )))
377
377
self ._assertCorrectOutputFile ('test_streaming_command_in_isolation.getinfo.csv' )
378
378
self ._assertCorrectOutputFile ('test_streaming_command_in_isolation.execute.csv' )
379
379
return
@@ -387,7 +387,7 @@ def test_streaming_command_on_server(self):
387
387
def _assertCorrectConfiguration (self , command , test_name ):
388
388
expected_file_location = os .path .join ('_expected_results' , test_name + '.txt' )
389
389
output_file_location = os .path .join ('output' , test_name + '.csv' )
390
- with TestSearchCommandsApp ._open_data_file (os .join ('input' , '_empty.csv' ), 'r' ) as input_file :
390
+ with TestSearchCommandsApp ._open_data_file (os .path . join ('input' , '_empty.csv' ), 'r' ) as input_file :
391
391
with TestSearchCommandsApp ._open_data_file (output_file_location , 'w' ) as output_file :
392
392
command .process (
393
393
[command .name , '__GETINFO__' , 'fieldname="foo"' ],
0 commit comments