tests: mark test connection required

tests/brokers/confluent/test_test_client.py

@@ -206,3 +206,7 @@ async def subscriber2(): ...
 
         assert subscriber1.mock.call_count == 1
         assert subscriber2.mock.call_count == 0
+
+    @pytest.mark.confluent()
+    async def test_broker_gets_patched_attrs_within_cm(self):
+        await super().test_broker_gets_patched_attrs_within_cm()

tests/brokers/kafka/test_test_client.py

@@ -254,3 +254,7 @@ async def subscriber2(): ...
 
         assert subscriber1.mock.call_count == 1
         assert subscriber2.mock.call_count == 0
+
+    @pytest.mark.kafka()
+    async def test_broker_gets_patched_attrs_within_cm(self):
+        await super().test_broker_gets_patched_attrs_within_cm()

tests/brokers/nats/test_test_client.py

@@ -255,3 +255,7 @@ def subscriber(m):
             await br.publish(1, f"{queue}.b")
             await br.publish(2, f"{queue}.a")
             subscriber.mock.assert_called_once_with(2)
+
+    @pytest.mark.nats()
+    async def test_broker_gets_patched_attrs_within_cm(self):
+        await super().test_broker_gets_patched_attrs_within_cm()

tests/brokers/rabbit/test_test_client.py

@@ -296,6 +296,10 @@ async def h2(msg): ...
 
         assert len(routes) == 2
 
+    @pytest.mark.rabbit()
+    async def test_broker_gets_patched_attrs_within_cm(self):
+        await super().test_broker_gets_patched_attrs_within_cm()
+
 
 @pytest.mark.parametrize(
     ("pattern", "current", "result"),

tests/brokers/redis/test_test_client.py

@@ -230,3 +230,7 @@ async def test_publish_to_none(
         async with self.patch_broker(broker) as br:
             with pytest.raises(ValueError):  # noqa: PT011
                 await br.publish("hello")
+
+    @pytest.mark.redis()
+    async def test_broker_gets_patched_attrs_within_cm(self):
+        await super().test_broker_gets_patched_attrs_within_cm()