Initial crack at defining a worker agent endpoint factory github/rei/worker_endpoint_factory rei/worker_endpoint_factory

TODO it's not being configured in the HTTP Client yet

1 files changed, 2 insertions, 0 deletions

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: