19
19
import rclpy
20
20
import rclpy .action
21
21
22
+ from rclpy .utilities import get_rmw_implementation_identifier
23
+
22
24
from ros2cli .node .daemon import DaemonNode
23
25
from ros2cli .node .daemon import is_daemon_running
24
26
from ros2cli .node .daemon import shutdown_daemon
@@ -214,8 +216,11 @@ def test_get_publishers_info_by_topic(daemon_node):
214
216
TEST_TOPIC_PUBLISHER_QOS .durability
215
217
assert test_publisher_info .qos_profile .reliability == \
216
218
TEST_TOPIC_PUBLISHER_QOS .reliability
217
- assert test_publisher_info .qos_profile .history == \
218
- TEST_TOPIC_PUBLISHER_QOS .history
219
+ if get_rmw_implementation_identifier () != 'rmw_connextdds' :
220
+ # rmw_connextdds does not collect the QoS history from discovery.
221
+ # See more details for https://github.com/ros2/ros2cli/issues/1054
222
+ assert test_publisher_info .qos_profile .history == \
223
+ TEST_TOPIC_PUBLISHER_QOS .history
219
224
220
225
221
226
def test_get_subscriptions_info_by_topic (daemon_node ):
@@ -229,10 +234,13 @@ def test_get_subscriptions_info_by_topic(daemon_node):
229
234
TEST_TOPIC_SUBSCRIPTION_QOS .durability
230
235
assert test_subscription_info .qos_profile .reliability == \
231
236
TEST_TOPIC_SUBSCRIPTION_QOS .reliability
232
- assert test_subscription_info .qos_profile .history == \
233
- TEST_TOPIC_SUBSCRIPTION_QOS .history
234
- assert test_subscription_info .qos_profile .depth == \
235
- TEST_TOPIC_SUBSCRIPTION_QOS .depth
237
+ if get_rmw_implementation_identifier () != 'rmw_connextdds' :
238
+ # rmw_connextdds does not collect the QoS history and depth from discovery
239
+ # See more details for https://github.com/ros2/ros2cli/issues/1054
240
+ assert test_subscription_info .qos_profile .history == \
241
+ TEST_TOPIC_SUBSCRIPTION_QOS .history
242
+ assert test_subscription_info .qos_profile .depth == \
243
+ TEST_TOPIC_SUBSCRIPTION_QOS .depth
236
244
237
245
238
246
def test_count_publishers (daemon_node ):
0 commit comments