Skip to content

Commit

Permalink
Address review comments in regards bag_path optimization
Browse files Browse the repository at this point in the history
Signed-off-by: Michael Orlov <michael.orlov@apex.ai>
  • Loading branch information
MichaelOrlov committed Mar 20, 2024
1 parent 51f5a0c commit c47b619
Showing 1 changed file with 5 additions and 6 deletions.
11 changes: 5 additions & 6 deletions rosbag2_py/test/test_transport.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@
# limitations under the License.

import datetime
from pathlib import Path
import threading

from common import get_rosbag_options, wait_for
Expand Down Expand Up @@ -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()

Expand Down Expand Up @@ -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))

0 comments on commit c47b619

Please sign in to comment.