@@ -333,39 +333,42 @@ def test_get_state(self):
333
333
supervisord = self ._makeOne (options )
334
334
self .assertEqual (supervisord .get_state (), SupervisorStates .RUNNING )
335
335
336
- def test_diff_to_active_added_and_removed (self ):
336
+ def test_diff_to_active_finds_groups_added (self ):
337
337
options = DummyOptions ()
338
338
supervisord = self ._makeOne (options )
339
339
340
340
pconfig = DummyPConfig (options , 'process1' , 'process1' )
341
341
group1 = DummyPGroupConfig (options , 'group1' , pconfigs = [pconfig ])
342
342
343
- pconfig = DummyPConfig (options , 'process2' , 'process2' )
344
- group2 = DummyPGroupConfig (options , 'group2' , pconfigs = [pconfig ])
345
-
346
- new = [group1 , group2 ]
347
- supervisord .options .process_group_configs = new
343
+ # the active configuration has no groups
344
+ # diffing should find that group1 has been added
345
+ supervisord .options .process_group_configs = [group1 ]
348
346
added , changed , removed = supervisord .diff_to_active ()
349
- self .assertEqual (added , new )
347
+ self .assertEqual (added , [ group1 ] )
350
348
self .assertEqual (changed , [])
351
349
self .assertEqual (removed , [])
352
350
353
- supervisord .add_process_group (group1 )
354
- supervisord .add_process_group (group2 )
351
+ def test_diff_to_active_finds_groups_removed (self ):
352
+ options = DummyOptions ()
353
+ supervisord = self ._makeOne (options )
355
354
356
- pconfig = DummyPConfig (options , 'process3 ' , 'process3 ' )
357
- new_group1 = DummyPGroupConfig (options , pconfigs = [pconfig ])
355
+ pconfig = DummyPConfig (options , 'process1 ' , 'process1 ' )
356
+ group1 = DummyPGroupConfig (options , 'group1' , pconfigs = [pconfig ])
358
357
359
- pconfig = DummyPConfig (options , 'process4 ' , 'process4 ' )
360
- new_group2 = DummyPGroupConfig (options , pconfigs = [pconfig ])
358
+ pconfig = DummyPConfig (options , 'process2 ' , 'process2 ' )
359
+ group2 = DummyPGroupConfig (options , 'group2' , pconfigs = [pconfig ])
361
360
362
- new = [group2 , new_group1 , new_group2 ]
361
+ # set up supervisord with an active configuration of group1 and group2
362
+ supervisord .options .process_group_configs = [group1 , group2 ]
363
+ supervisord .add_process_group (group1 )
364
+ supervisord .add_process_group (group2 )
363
365
364
- supervisord .options .process_group_configs = new
366
+ # diffing should find that group2 has been removed
367
+ supervisord .options .process_group_configs = [group1 ]
365
368
added , changed , removed = supervisord .diff_to_active ()
366
- self .assertEqual (added , [new_group1 , new_group2 ])
369
+ self .assertEqual (added , [])
367
370
self .assertEqual (changed , [])
368
- self .assertEqual (removed , [group1 ])
371
+ self .assertEqual (removed , [group2 ])
369
372
370
373
def test_diff_to_active_changed (self ):
371
374
from supervisor .options import ProcessConfig , ProcessGroupConfig
@@ -575,7 +578,7 @@ def test_add_process_group(self):
575
578
self .assertEqual (group , supervisord .process_groups ['foo' ])
576
579
self .assertTrue (not result )
577
580
578
- def test_add_process_group_event (self ):
581
+ def test_add_process_group_emits_event (self ):
579
582
from supervisor import events
580
583
L = []
581
584
def callback (event ):
0 commit comments