update logging to log when batch is empty on flush or flush of batch size

Author: thomaszurkan-optimizely

optimizely/event/event_processor.py

@@ -222,10 +222,13 @@ def flush(self):
 
     def _flush_queue(self):
         """ Flushes event_queue by dispatching events. """
-        self.logger.debug('Flushing the queue.')
-        if len(self._current_batch) == 0:
+        batch_len = len(self._current_batch)
+        if batch_len == 0:
+            self.logger.debug('Nothing to flush.')
             return
 
+        self.logger.debug('Flushing batch size ' + str(batch_len))
+
         with self.LOCK:
             to_process_batch = list(self._current_batch)
             self._current_batch = list()

tests/test_event_processor.py

@@ -179,7 +179,7 @@ def test_flush_once_max_timeout(self):
         self.optimizely.logger = SimpleLogger(enums.LogLevels.DEBUG)
 
         with mock.patch.object(self.optimizely, 'logger') as mock_config_logging:
-            self._set_event_processor(event_dispatcher, mock_config_logging)
+            self._set_event_processor(event_dispatcher, self.optimizely.logger)
 
         user_event = self._build_conversion_event(self.event_name)
         self.event_processor.process(user_event)
@@ -192,7 +192,8 @@ def test_flush_once_max_timeout(self):
         self.assertTrue(mock_config_logging.debug.called)
         mock_config_logging.debug.assert_any_call('Received event of type ConversionEvent for user test_user.')
         mock_config_logging.debug.assert_any_call('Flush interval deadline. Flushed queue.')
-        self.assertTrue(mock_config_logging.debug.call_count == 2)
+        mock_config_logging.debug.assert_any_call('Flushing batch size 1')
+        self.assertTrue(mock_config_logging.debug.call_count == 3)
         self.optimizely.logger = SimpleLogger()
 
     def test_flush_max_batch_size(self):