WIP Allow skipping if txredisapi is not installed?

Author: reivilibre

tests/replication/tcp/test_redis.py

@@ -12,7 +12,10 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-from synapse.replication.tcp.redis import RedisDirectTcpReplicationClientFactory
+try:
+    import txredisapi
+except ImportError:
+    txredisapi = None
 
 from tests.replication._base import BaseMultiWorkerStreamTestCase
 from tests.unittest import HomeserverTestCase
@@ -38,7 +41,12 @@
 
 
 class RedisTestCase(HomeserverTestCase):
+    if txredisapi is None:
+        skip = "Redis extras not installed"
+
     def test_subscribed_to_enough_redis_channels(self) -> None:
+        from synapse.replication.tcp.redis import RedisDirectTcpReplicationClientFactory
+
         # The default main process is subscribed to USER_IP and all RDATA channels.
         self.assertCountEqual(
             RedisDirectTcpReplicationClientFactory.channels_to_subscribe_to_for_config(
@@ -52,7 +60,12 @@ def test_subscribed_to_enough_redis_channels(self) -> None:
 
 
 class RedisWorkerTestCase(BaseMultiWorkerStreamTestCase):
+    if txredisapi is None:
+        skip = "Redis extras not installed"
+
     def test_background_worker_subscribed_to_user_ip(self) -> None:
+        from synapse.replication.tcp.redis import RedisDirectTcpReplicationClientFactory
+
         # The default main process is subscribed to USER_IP and all RDATA channels.
         worker1 = self.make_worker_hs(
             "synapse.app.generic_worker",
@@ -69,6 +82,8 @@ def test_background_worker_subscribed_to_user_ip(self) -> None:
         )
 
     def test_non_background_worker_not_subscribed_to_user_ip(self) -> None:
+        from synapse.replication.tcp.redis import RedisDirectTcpReplicationClientFactory
+
         # The default main process is subscribed to USER_IP and all RDATA channels.
         worker2 = self.make_worker_hs(
             "synapse.app.generic_worker",