@@ -123,15 +123,16 @@ def _build_conversion_event(self, event_name, project_config=None):
123
123
return UserEventFactory .create_conversion_event (config , event_name , self .test_user_id , {}, {})
124
124
125
125
def _set_event_processor (self , event_dispatcher , logger ):
126
- self .event_processor = BatchEventProcessor (event_dispatcher ,
127
- logger ,
128
- True ,
129
- self .event_queue ,
130
- self .MAX_BATCH_SIZE ,
131
- self .MAX_DURATION_SEC ,
132
- self .MAX_TIMEOUT_INTERVAL_SEC ,
133
- self .optimizely .notification_center
134
- )
126
+ self .event_processor = BatchEventProcessor (
127
+ event_dispatcher ,
128
+ logger ,
129
+ True ,
130
+ self .event_queue ,
131
+ self .MAX_BATCH_SIZE ,
132
+ self .MAX_DURATION_SEC ,
133
+ self .MAX_TIMEOUT_INTERVAL_SEC ,
134
+ self .optimizely .notification_center
135
+ )
135
136
136
137
def test_drain_on_stop (self ):
137
138
event_dispatcher = TestEventDispatcher ()
@@ -450,18 +451,20 @@ def setUp(self, *args, **kwargs):
450
451
self .event_dispatcher = TestForwardingEventDispatcher (is_updated = False )
451
452
452
453
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
453
- self .event_processor = ForwardingEventProcessor (self .event_dispatcher ,
454
- mock_config_logging ,
455
- self .notification_center
456
- )
454
+ self .event_processor = ForwardingEventProcessor (
455
+ self .event_dispatcher ,
456
+ mock_config_logging ,
457
+ self .notification_center
458
+ )
457
459
458
460
def _build_conversion_event (self , event_name ):
459
- return UserEventFactory .create_conversion_event (self .project_config ,
460
- event_name ,
461
- self .test_user_id ,
462
- {},
463
- {}
464
- )
461
+ return UserEventFactory .create_conversion_event (
462
+ self .project_config ,
463
+ event_name ,
464
+ self .test_user_id ,
465
+ {},
466
+ {}
467
+ )
465
468
466
469
def test_event_processor__dispatch_raises_exception (self ):
467
470
""" Test that process logs dispatch failure gracefully. """
0 commit comments