Update tests

Author: hectorhdzg

opentelemetry-sdk/src/opentelemetry/sdk/_logs/_internal/export/__init__.py

@@ -187,7 +187,7 @@ def __init__(
         )
 
     def on_emit(self, log_data: LogData) -> None:
-        return self._batch_processor.on_emit(log_data)
+        return self._batch_processor.emit(log_data)
 
     def shutdown(self):
         return self._batch_processor.shutdown()

opentelemetry-sdk/tests/logs/test_export.py

@@ -348,7 +348,7 @@ def test_emit_call_log_record(self):
         logger.addHandler(LoggingHandler(logger_provider=provider))
 
         logger.error("error")
-        self.assertEqual(log_record_processor.emit.call_count, 1)
+        self.assertEqual(log_record_processor.on_emit.call_count, 1)
         log_record_processor.shutdown()
 
     def test_with_multiple_threads(self):  # pylint: disable=no-self-use
@@ -363,7 +363,7 @@ def test_with_multiple_threads(self):  # pylint: disable=no-self-use
 
         def bulk_emit(num_emit):
             for _ in range(num_emit):
-                batch_processor.emit(EMPTY_LOG)
+                batch_processor.on_emit(EMPTY_LOG)
 
         total_expected_logs = 0
         with ThreadPoolExecutor(max_workers=69) as executor:
@@ -404,10 +404,10 @@ def test_logging_lib_not_invoked_in_batch_log_record_emit(self):  # pylint: disa
         # If `emit` calls logging.log then this test will throw a maximum recursion depth exceeded exception and fail.
         try:
             with self.assertNoLogs(sdk_logger, logging.NOTSET):
-                processor.emit(EMPTY_LOG)
+                processor.on_emit(EMPTY_LOG)
             processor.shutdown()
             with self.assertNoLogs(sdk_logger, logging.NOTSET):
-                processor.emit(EMPTY_LOG)
+                processor.on_emit(EMPTY_LOG)
         finally:
             sdk_logger.removeHandler(handler)
 

opentelemetry-sdk/tests/logs/test_handler.py

@@ -384,7 +384,7 @@ class FakeProcessor(LogRecordProcessor):
     def __init__(self):
         self.log_data_emitted = []
 
-    def emit(self, log_data: LogData):
+    def on_emit(self, log_data: LogData):
         self.log_data_emitted.append(log_data)
 
     def shutdown(self):

opentelemetry-sdk/tests/logs/test_multi_log_processor.py

@@ -38,7 +38,7 @@ def __init__(self, exporter, logs_list):
         self._log_list = logs_list
         self._closed = False
 
-    def emit(self, log_data):
+    def on_emit(self, log_data):
         if self._closed:
             return
         self._log_list.append(
@@ -118,9 +118,9 @@ def test_on_emit(self):
         for mock in mocks:
             multi_log_record_processor.add_log_record_processor(mock)
         record = self.make_record()
-        multi_log_record_processor.emit(record)
+        multi_log_record_processor.on_emit(record)
         for mock in mocks:
-            mock.emit.assert_called_with(record)
+            mock.on_emit.assert_called_with(record)
         multi_log_record_processor.shutdown()
 
     def test_on_shutdown(self):