From d7a1948a47683d6e01d61bbe295029357b931e82 Mon Sep 17 00:00:00 2001 From: "Olivier Wilkinson (reivilibre)" Date: Wed, 5 Apr 2023 12:37:38 +0100 Subject: Initial crack at defining a worker agent endpoint factory TODO it's not being configured in the HTTP Client yet --- tests/replication/_base.py | 2 ++ 1 file changed, 2 insertions(+) (limited to 'tests/replication/_base.py') diff --git a/tests/replication/_base.py b/tests/replication/_base.py index 0f1a8a145f..0364c888ac 100644 --- a/tests/replication/_base.py +++ b/tests/replication/_base.py @@ -22,6 +22,7 @@ from twisted.test.proto_helpers import MemoryReactor from twisted.web.resource import Resource from synapse.app.generic_worker import GenericWorkerServer +from synapse.config.workers import TcpInstanceLocationConfig from synapse.http.site import SynapseRequest, SynapseSite from synapse.replication.http import ReplicationRestResource from synapse.replication.tcp.client import ReplicationDataHandler @@ -339,6 +340,7 @@ class BaseMultiWorkerStreamTestCase(unittest.HomeserverTestCase): # `_handle_http_replication_attempt` like we do with the master HS. instance_name = worker_hs.get_instance_name() instance_loc = worker_hs.config.worker.instance_map.get(instance_name) + assert isinstance(instance_loc, TcpInstanceLocationConfig) if instance_loc: # Ensure the host is one that has a fake DNS entry. if instance_loc.host not in self.reactor.lookups: -- cgit 1.5.1