switch to anyio to async testing, add unit test

otel_extensions/__init__.py

@@ -361,7 +361,7 @@ async def new_f_async(*args: Any, **kwargs: Any) -> Any:
         )
 
     def _module_allowed(self, func_module_path: str) -> bool:
-        if self.process_modules is None or self.process_modules == "":
+        if not self.process_modules:
             return True
 
         modules = self.process_modules.split(",")

pyproject.toml

@@ -89,6 +89,12 @@ addopts = "-ra --showlocals -vv"
 testpaths = ["tests"]
 xfail_strict = true
 junit_family = "xunit2"
+log_cli = 1
+log_cli_level = "INFO"
+log_cli_format = "%(asctime)s [%(levelname)8s] %(name)s - %(message)s"
+log_cli_date_format = "%Y-%m-%d %H:%M:%S"
+log_format = "%(asctime)s [%(levelname)8s] %(name)s - %(message)s"
+log_date_format = "%Y-%m-%d %H:%M:%S"
 
 [tool.mypy]
 python_version = "3.8"

test-requirements.txt

@@ -1,6 +1,6 @@
 pytest
 pytest-cov
 opentelemetry-distro[otlp]
-pytest-asyncio
+anyio
 mypy
 pre-commit

tests/conftest.py

@@ -1 +1,6 @@
-pytest_plugins = "pytest_asyncio"
+import pytest
+
+
+@pytest.fixture
+def anyio_backend():
+    return "asyncio"

tests/test_decorator.py

@@ -1,8 +1,11 @@
-from otel_extensions import instrumented
-from opentelemetry import trace
-from opentelemetry.sdk.trace import ReadableSpan
+import os
 from collections.abc import Sequence
+
 import pytest
+from opentelemetry import trace
+from opentelemetry.sdk.trace import ReadableSpan
+
+from otel_extensions import instrumented
 
 SPAN_ATTRS = {
     "foo": "bar",
@@ -79,16 +82,39 @@ def test_decorator_with_span_attributes():
     decorated_function_with_span_attrs()
 
 
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_async_decorator_with_default_name():
     await decorated_async_function()
 
 
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_async_decorator_with_custom_name():
     await decorated_async_function_with_custom_name()
 
 
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_async_decorator_with_span_attributes():
     await decorated_async_function_with_span_attrs()
+
+
+@pytest.fixture
+def otel_process_modules(request):
+    if request.param is not None:
+        os.environ["OTEL_PROCESS_MODULES"] = request.param
+    yield request.param
+    os.environ.pop("OTEL_PROCESS_MODULES", None)
+
+
+@pytest.mark.parametrize(
+    "otel_process_modules", ["foo", "", None, "test_decorator"], indirect=True
+)
+def test_decorator_with_module_filter(otel_process_modules):
+    @instrumented(span_name="decorated_function_with_module_filter")
+    def decorated_local_function():
+        span: ReadableSpan = trace.get_current_span()  # noqa
+        if otel_process_modules == "foo":
+            assert span.name == "test_decorator_with_module_filter[foo] (call)"
+        else:
+            assert span.name == "decorated_function_with_module_filter"
+
+    decorated_local_function()