diff --git a/tests/integration/observability/conftest.py b/tests/integration/observability/conftest.py
index 101c2958b64..eb5c12a1cea 100644
--- a/tests/integration/observability/conftest.py
+++ b/tests/integration/observability/conftest.py
@@ -34,7 +34,7 @@ def langfuse_vars(audit_sinks: SpanSinks) -> dict[str, JsonValue]:
     return langfuse_callback_variables(audit_sinks)
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture(scope="module")
 def capped(tmp_path_factory: pytest.TempPathFactory) -> Iterator[CapRig]:
     """A two-worker proxy capped at three series per metric, with three keys already holding a series each."""
     with series_cap_rig(
diff --git a/tests/integration/observability/test_otel_conversation_id.py b/tests/integration/observability/test_otel_conversation_id.py
index af893abab48..d7f4de2961b 100644
--- a/tests/integration/observability/test_otel_conversation_id.py
+++ b/tests/integration/observability/test_otel_conversation_id.py
@@ -305,12 +305,12 @@ class RigFactory:
             yield Rig(owned.gateway, owned, model, self.provider, self.sink)
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture(scope="module")
 def rig(provider: Wire, collector: Collector, tmp_path_factory: pytest.TempPathFactory) -> Iterator[Rig]:
     yield from RigFactory(provider, collector, tmp_path_factory.mktemp("otel"), {}, 2).start()
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture(scope="module")
 def generating_rig(provider: Wire, collector: Collector, tmp_path_factory: pytest.TempPathFactory) -> Iterator[Rig]:
     factory: Final = RigFactory(
         provider, collector, tmp_path_factory.mktemp("otel-generate"), {"missing_session_id": "generate"}, 2
@@ -318,7 +318,7 @@ def generating_rig(provider: Wire, collector: Collector, tmp_path_factory: pytes
     yield from factory.start()
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture(scope="module")
 def two_worker_rig(provider: Wire, collector: Collector, tmp_path_factory: pytest.TempPathFactory) -> Iterator[Rig]:
     yield from RigFactory(provider, collector, tmp_path_factory.mktemp("otel-workers"), {}, 2).start()
 
diff --git a/tests/integration/observability/test_signoz_delivery.py b/tests/integration/observability/test_signoz_delivery.py
index 6e50a9bedf5..e25126e4fa8 100644
--- a/tests/integration/observability/test_signoz_delivery.py
+++ b/tests/integration/observability/test_signoz_delivery.py
@@ -424,7 +424,7 @@ class RigFactory:
             yield Rig(owned.gateway, owned, model, self.provider, self.sink, self.tenant_sink)
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture(scope="module")
 def rig(
     provider: Wire, operator_sink: Collector, tenant_sink: Collector, tmp_path_factory: pytest.TempPathFactory
 ) -> Iterator[Rig]:
@@ -434,7 +434,7 @@ def rig(
     yield from factory.start()
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture(scope="module")
 def v2_rig(
     provider: Wire, operator_sink: Collector, tenant_sink: Collector, tmp_path_factory: pytest.TempPathFactory
 ) -> Iterator[Rig]: