Add missing scope field in the log formatter

Author: sfc-gh-bnandibhatla

src/snowflake/telemetry/logs/__init__.py

@@ -34,12 +34,15 @@
         "threadName",
         "taskName",
         # Params that Snowflake will populate and don't want users of this API to overwrite.
+        "body",
         "code.lineno",
         "code.function",
         "code.filepath",
         "exception.type",
         "exception.message",
         "exception.stacktrace",
+        "scope",
+        "severity_text",
     )
 )
 
@@ -75,6 +78,9 @@ def get_severity_text(py_level_name):
 
     def format(self, record: logging.LogRecord) -> str:
         log_items = {
+            "scope": {
+                "name": record.name,
+            },
             "body": record.getMessage(),
             "severity_text": self.get_severity_text(record.levelname),
             "code.lineno": record.lineno,

tests/test_snowflake_log_formatter.py

@@ -20,6 +20,9 @@ def test_normal_log(self):
         """ Does the logger produce the correct output? """
         self.root_logger.warning('foo', extra={"test": 123, "code.lineno": 35})
         expected_log_message = {
+            "scope": {
+                "name": "test",
+            },
             "body": "foo",
             "severity_text": "WARN",
             "code.lineno": 21,
@@ -39,17 +42,20 @@ def test_exception_log(self):
             self.root_logger.exception("\"test exception\"")
 
         expected_log_message = {
+            "scope": {
+                "name": "test",
+            },
             "body": "\"test exception\"",
             "severity_text": "ERROR",
-            "code.lineno": 39,
+            "code.lineno": 42,
             "code.function": "test_exception_log",
             "exception.type": "ZeroDivisionError",
             "exception.message": "division by zero",
         }
         actual_log_message = json.loads(self.stream.getvalue(), strict=False)
         actual_log_message.pop("code.filepath")
         actual_stacktrace = actual_log_message.pop("exception.stacktrace")
-        self.assertIn("line 37, in test_exception_log\n", actual_stacktrace)
+        self.assertIn("line 40, in test_exception_log\n", actual_stacktrace)
         self.assertIn("ZeroDivisionError: division by zero\n", actual_stacktrace)
         self.assertEqual(expected_log_message, actual_log_message)