googleapis
diff --git a/‎google/cloud/logging_v2/_instrumentation.py
Copy file name to clipboardExpand all lines: google/cloud/logging_v2/_instrumentation.py
+4-2Lines changed: 4 additions & 2 deletions b/‎google/cloud/logging_v2/_instrumentation.py
Copy file name to clipboardExpand all lines: google/cloud/logging_v2/_instrumentation.py
+4-2Lines changed: 4 additions & 2 deletions
diff --git a/‎tests/unit/test__instrumentation.py
Copy file name to clipboardExpand all lines: tests/unit/test__instrumentation.py
+16Lines changed: 16 additions & 0 deletions b/‎tests/unit/test__instrumentation.py
Copy file name to clipboardExpand all lines: tests/unit/test__instrumentation.py
+16Lines changed: 16 additions & 0 deletions
@@ -67,8 +67,10 @@ def _create_diagnostic_entry(name=_PYTHON_LIBRARY_NAME, version=_LIBRARY_VERSION
             _INSTRUMENTATION_SOURCE_KEY: [_get_instrumentation_source(name, version)]
         }
     }
-    kw["severity"] = "INFO"
-    entry = StructEntry(payload=payload, **kw)
+    # only keep the log_name and resource from the parent log
+    allow_list = ("log_name", "resource")
+    active_kws = {k: v for k, v in kw.items() if k in allow_list}
+    entry = StructEntry(payload=payload, **active_kws)
     return entry
 
 
 
@@ -63,3 +63,19 @@ def test_truncate_long_values(self):
 
         self.assertEqual(expected_name, self._get_diagonstic_value(entry, "name"))
         self.assertEqual(expected_version, self._get_diagonstic_value(entry, "version"))
+
+    def test_drop_labels(self):
+        """Labels should not be copied in instrumentation log"""
+        test_logname = "test-name"
+        test_labels = {"hello": "world"}
+        entry = i._create_diagnostic_entry(
+            name=self.LONG_NAME,
+            version=self.LONG_VERSION,
+            log_name=test_logname,
+            labels=test_labels,
+        )
+        self.assertEqual(entry.log_name, test_logname)
+        self.assertIsNone(entry.labels)
+        # ensure only expected fields exist in entry
+        expected_keys = set(["logName", "resource", "jsonPayload"])
+        self.assertEqual(set(entry.to_api_repr().keys()), expected_keys)
Original file line number	Diff line number	Diff line change
`@@ -67,8 +67,10 @@ def _create_diagnostic_entry(name=_PYTHON_LIBRARY_NAME, version=_LIBRARY_VERSION`
`67`	`67`	`_INSTRUMENTATION_SOURCE_KEY: [_get_instrumentation_source(name, version)]`
`68`	`68`	`}`
`69`	`69`	`}`
`70`		`- kw["severity"] = "INFO"`
`71`		`- entry = StructEntry(payload=payload, **kw)`
	`70`	`+ # only keep the log_name and resource from the parent log`
	`71`	`+ allow_list = ("log_name", "resource")`
	`72`	`+ active_kws = {k: v for k, v in kw.items() if k in allow_list}`
	`73`	`+ entry = StructEntry(payload=payload, **active_kws)`
`72`	`74`	`return entry`
`73`	`75`
`74`	`76`