3232class FakeFlags (object ):
3333 def __init__ (
3434 self ,
35- logdir ,
35+ generic_data = "auto" ,
36+ logdir = "" ,
3637 logdir_spec = "" ,
37- purge_orphaned_data = True ,
38- reload_interval = 60 ,
39- samples_per_plugin = None ,
4038 max_reload_threads = 1 ,
41- reload_task = "auto" ,
42- window_title = "" ,
4339 path_prefix = "" ,
40+ purge_orphaned_data = True ,
41+ reload_interval = 60 ,
4442 reload_multifile = False ,
4543 reload_multifile_inactive_secs = 4000 ,
46- generic_data = "auto" ,
44+ reload_task = "auto" ,
45+ samples_per_plugin = None ,
46+ window_title = "" ,
4747 ):
48+ self .generic_data = generic_data
4849 self .logdir = logdir
4950 self .logdir_spec = logdir_spec
50- self .purge_orphaned_data = purge_orphaned_data
51- self .reload_interval = reload_interval
52- self .samples_per_plugin = samples_per_plugin or {}
5351 self .max_reload_threads = max_reload_threads
54- self .reload_task = reload_task
55- self .window_title = window_title
5652 self .path_prefix = path_prefix
53+ self .purge_orphaned_data = purge_orphaned_data
54+ self .reload_interval = reload_interval
5755 self .reload_multifile = reload_multifile
5856 self .reload_multifile_inactive_secs = reload_multifile_inactive_secs
59- self .generic_data = generic_data
57+ self .reload_task = reload_task
58+ self .samples_per_plugin = samples_per_plugin or {}
59+ self .window_title = window_title
6060
6161
6262class GetEventFileActiveFilterTest (tb_test .TestCase ):
6363 def testDisabled (self ):
64- flags = FakeFlags ("logdir" , reload_multifile = False )
64+ flags = FakeFlags (logdir = "logdir" , reload_multifile = False )
6565 self .assertIsNone (data_ingester ._get_event_file_active_filter (flags ))
6666
6767 def testInactiveSecsZero (self ):
6868 flags = FakeFlags (
69- "logdir" , reload_multifile = True , reload_multifile_inactive_secs = 0
69+ logdir = "logdir" ,
70+ reload_multifile = True ,
71+ reload_multifile_inactive_secs = 0 ,
7072 )
7173 self .assertIsNone (data_ingester ._get_event_file_active_filter (flags ))
7274
7375 def testInactiveSecsNegative (self ):
7476 flags = FakeFlags (
75- "logdir" , reload_multifile = True , reload_multifile_inactive_secs = - 1
77+ logdir = "logdir" ,
78+ reload_multifile = True ,
79+ reload_multifile_inactive_secs = - 1 ,
7680 )
7781 filter_fn = data_ingester ._get_event_file_active_filter (flags )
7882 self .assertTrue (filter_fn (0 ))
@@ -81,7 +85,9 @@ def testInactiveSecsNegative(self):
8185
8286 def testInactiveSecs (self ):
8387 flags = FakeFlags (
84- "logdir" , reload_multifile = True , reload_multifile_inactive_secs = 10
88+ logdir = "logdir" ,
89+ reload_multifile = True ,
90+ reload_multifile_inactive_secs = 10 ,
8591 )
8692 filter_fn = data_ingester ._get_event_file_active_filter (flags )
8793 with mock .patch .object (time , "time" ) as mock_time :
@@ -378,15 +384,19 @@ def testCheckFilesystemSupport_Called(self):
378384 with mock .patch .object (
379385 data_ingester , "_check_filesystem_support" , autospec = True
380386 ) as mock_check_filesystem_support :
381- data_ingester .LocalDataIngester (flags = FakeFlags ("logdir" ))
387+ data_ingester .LocalDataIngester (
388+ flags = FakeFlags (logdir = "logdir" )
389+ )
382390 mock_check_filesystem_support .assert_called_once_with ({"logdir" })
383391
384392 def testCheckFilesystemSupport_notCalled (self ):
385393 with mock .patch .object (tf , "__version__" , new = "stub" ):
386394 with mock .patch .object (
387395 data_ingester , "_check_filesystem_support" , autospec = True
388396 ) as mock_check_filesystem_support :
389- data_ingester .LocalDataIngester (flags = FakeFlags ("logdir" ))
397+ data_ingester .LocalDataIngester (
398+ flags = FakeFlags (logdir = "logdir" )
399+ )
390400 mock_check_filesystem_support .assert_not_called ()
391401
392402
0 commit comments