diff --git a/ddtrace/internal/datastreams/processor.py b/ddtrace/internal/datastreams/processor.py
index 976d048b46c..fff8c4c9569 100644
--- a/ddtrace/internal/datastreams/processor.py
+++ b/ddtrace/internal/datastreams/processor.py
@@ -3,7 +3,6 @@
 from collections import defaultdict
 from functools import partial
 import gzip
-import os
 import struct
 import threading
 import time
@@ -16,6 +15,7 @@
 from ddtrace.internal.atexit import register_on_exit_signal
 from ddtrace.internal.constants import DEFAULT_SERVICE_NAME
 from ddtrace.internal.native import DDSketch
+from ddtrace.internal.settings import env
 from ddtrace.internal.settings._agent import config as agent_config
 from ddtrace.internal.settings._config import config
 from ddtrace.internal.threads import Lock
@@ -50,7 +50,6 @@ def gzip_compress(payload):
 https://docs.datadoghq.com/data_streams/
 """
 
-
 log = get_logger(__name__)
 
 PROPAGATION_KEY = "dd-pathway-ctx"
@@ -103,7 +102,7 @@ def __init__(
         retry_attempts: int = 3,
     ):
         if interval is None:
-            interval = float(os.getenv("_DD_TRACE_STATS_WRITER_INTERVAL") or 10.0)
+            interval = float(env.get("_DD_TRACE_STATS_WRITER_INTERVAL") or 10.0)
         super(DataStreamsProcessor, self).__init__(interval=interval)
         self._enabled: bool = True
         self._agent_url = agent_url or agent_config.trace_agent_url