From c47b619bb389120023dca069ad4630ea2b3e1ce8 Mon Sep 17 00:00:00 2001 From: Michael Orlov Date: Wed, 20 Mar 2024 14:38:41 -0700 Subject: [PATCH] Address review comments in regards bag_path optimization Signed-off-by: Michael Orlov --- rosbag2_py/test/test_transport.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/rosbag2_py/test/test_transport.py b/rosbag2_py/test/test_transport.py index 57f714d66..e33da3bdf 100644 --- a/rosbag2_py/test/test_transport.py +++ b/rosbag2_py/test/test_transport.py @@ -13,7 +13,6 @@ # limitations under the License. import datetime -from pathlib import Path import threading from common import get_rosbag_options, wait_for @@ -44,8 +43,8 @@ def test_options_qos_conversion(): @pytest.mark.parametrize('storage_id', TESTED_STORAGE_IDS) def test_record_cancel(tmp_path, storage_id): - bag_path = str(tmp_path / 'test_record_cancel') - storage_options, converter_options = get_rosbag_options(bag_path, storage_id) + bag_path = tmp_path / 'test_record_cancel' + storage_options, converter_options = get_rosbag_options(str(bag_path), storage_id) recorder = rosbag2_py.Recorder() @@ -78,12 +77,12 @@ def test_record_cancel(tmp_path, storage_id): recorder.cancel() metadata_io = rosbag2_py.MetadataIo() - assert wait_for(lambda: metadata_io.metadata_file_exists(bag_path), + assert wait_for(lambda: metadata_io.metadata_file_exists(str(bag_path)), timeout=rclpy.duration.Duration(seconds=3)) record_thread.join() - metadata = metadata_io.read_metadata(bag_path) + metadata = metadata_io.read_metadata(str(bag_path)) assert len(metadata.relative_file_paths) - storage_path = Path(bag_path + '/' + metadata.relative_file_paths[0]) + storage_path = bag_path / metadata.relative_file_paths[0] assert wait_for(lambda: storage_path.is_file(), timeout=rclpy.duration.Duration(seconds=3))