improve tests

Author: dubloom

tests/debugging/test_encoding.py

@@ -270,34 +270,39 @@ def test_process_tags_are_not_included_by_default():
     assert "process_tags" not in decoded[0]
 
 
+@pytest.mark.subprocess(
+    env=dict(
+        DD_EXPERIMENTAL_PROPAGATE_PROCESS_TAGS_ENABLED="true",
+    )
+)
 def test_process_tags_are_included():
-    from ddtrace.internal.settings._config import config
-    from tests.utils import process_tag_reload
+    import inspect
+    import json
+    import threading
 
-    try:
-        config._process_tags_enabled = True
-        process_tag_reload()
-        s = Snapshot(
-            probe=create_snapshot_line_probe(probe_id="batch-test", source_file="foo.py", line=42),
-            frame=inspect.currentframe(),
-            thread=threading.current_thread(),
-        )
-        buffer_size = 30 * (1 << 20)
-        queue = SignalQueue(encoder=LogSignalJsonEncoder(None), buffer_size=buffer_size)
-
-        s.line({})
-
-        queue = SignalQueue(encoder=LogSignalJsonEncoder("test-service"))
-        queue.put(s)
-        data = queue.flush()
-        assert data is not None
-        payload, _ = data
-        decoded = json.loads(payload.decode())
-
-        assert "process_tags" in decoded[0]
-    finally:
-        config._process_tags_enabled = False
-        process_tag_reload()
+    from ddtrace.debugging._encoding import LogSignalJsonEncoder
+    from ddtrace.debugging._encoding import SignalQueue
+    from ddtrace.debugging._signal.snapshot import Snapshot
+    from tests.debugging.utils import create_snapshot_line_probe
+
+    s = Snapshot(
+        probe=create_snapshot_line_probe(probe_id="batch-test", source_file="foo.py", line=42),
+        frame=inspect.currentframe(),
+        thread=threading.current_thread(),
+    )
+    buffer_size = 30 * (1 << 20)
+    queue = SignalQueue(encoder=LogSignalJsonEncoder(None), buffer_size=buffer_size)
+
+    s.line({})
+
+    queue = SignalQueue(encoder=LogSignalJsonEncoder("test-service"))
+    queue.put(s)
+    data = queue.flush()
+    assert data is not None
+    payload, _ = data
+    decoded = json.loads(payload.decode())
+
+    assert "process_tags" in decoded[0]
 
 
 def test_batch_flush_reencode():