Add test case

Author: ocelotl

opentelemetry-sdk/CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- Add support for OTEL_BSP_X environment variables
+  ([#1105](https://github.com/open-telemetry/opentelemetry-python/pull/1105))
 - Moved samplers from API to SDK
   ([#1023](https://github.com/open-telemetry/opentelemetry-python/pull/1023))
 - Sampling spec changes

opentelemetry-sdk/src/opentelemetry/sdk/trace/export/__init__.py

@@ -120,23 +120,21 @@ def __init__(
     ):
 
         if max_queue_size is None:
-            max_queue_size = Configuration().get(
-                "OTEL_BSP_MAX_QUEUE_SIZE", 2048
-            )
+            max_queue_size = Configuration().get("BSP_MAX_QUEUE_SIZE", 2048)
 
         if schedule_delay_millis is None:
             schedule_delay_millis = Configuration().get(
-                "OTEL_BSP_SCHEDULE_DELAY_MILLIS", 5000
+                "BSP_SCHEDULE_DELAY_MILLIS", 5000
             )
 
         if max_export_batch_size is None:
             max_export_batch_size = Configuration().get(
-                "OTEL_BSP_MAX_EXPORT_BATCH_SIZE", 512
+                "BSP_MAX_EXPORT_BATCH_SIZE", 512
             )
 
         if export_timeout_millis is None:
             export_timeout_millis = Configuration().get(
-                "OTEL_BSP_EXPORT_TIMEOUT_MILLIS", 30000
+                "BSP_EXPORT_TIMEOUT_MILLIS", 30000
             )
 
         if max_queue_size <= 0:

opentelemetry-sdk/tests/trace/export/test_export.py

@@ -136,6 +136,26 @@ def _create_start_and_end_span(name, span_processor):
 
 
 class TestBatchExportSpanProcessor(unittest.TestCase):
+    @mock.patch.dict(
+        "os.environ",
+        {
+            "OTEL_BSP_MAX_QUEUE_SIZE": "10",
+            "OTEL_BSP_SCHEDULE_DELAY_MILLIS": "2",
+            "OTEL_BSP_MAX_EXPORT_BATCH_SIZE": "3",
+            "OTEL_BSP_EXPORT_TIMEOUT_MILLIS": "4",
+        },
+    )
+    def test_batch_span_processor_environment_variables(self):
+
+        batch_span_processor = export.BatchExportSpanProcessor(
+            MySpanExporter(destination=[])
+        )
+
+        self.assertEqual(batch_span_processor.max_queue_size, 10)
+        self.assertEqual(batch_span_processor.schedule_delay_millis, 2)
+        self.assertEqual(batch_span_processor.max_export_batch_size, 3)
+        self.assertEqual(batch_span_processor.export_timeout_millis, 4)
+
     def test_shutdown(self):
         spans_names_list = []