mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-04 06:53:07 +00:00
fixes
This commit is contained in:
parent
ef7ffac51f
commit
48f844c186
@ -93,7 +93,7 @@ class TestRunningNodesAutosharding(StepsSharding):
|
|||||||
self.check_published_message_reaches_relay_peer(pubsub_topic=self.test_pubsub_topic)
|
self.check_published_message_reaches_relay_peer(pubsub_topic=self.test_pubsub_topic)
|
||||||
|
|
||||||
def test_sender_uses_auto_api_receiver_uses_regular_api(self):
|
def test_sender_uses_auto_api_receiver_uses_regular_api(self):
|
||||||
self.setup_main_relay_nodes(cluster_id=self.auto_cluster, pubsub_topic=self.test_pubsub_topic)
|
self.setup_main_relay_nodes(cluster_id=self.auto_cluster, pubsub_topic=self.test_pubsub_topic, num_shards_in_network=1)
|
||||||
self.subscribe_first_relay_node(content_topics=[self.test_content_topic])
|
self.subscribe_first_relay_node(content_topics=[self.test_content_topic])
|
||||||
self.subscribe_second_relay_node(pubsub_topics=[self.test_pubsub_topic])
|
self.subscribe_second_relay_node(pubsub_topics=[self.test_pubsub_topic])
|
||||||
self.relay_message(self.node1, self.create_message(contentTopic=self.test_content_topic))
|
self.relay_message(self.node1, self.create_message(contentTopic=self.test_content_topic))
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user