code: def test_read_binary_files_with_fs(ray_start_regular_shared):
      with gen_bin_files(10) as (tempdir, paths):
          # All the paths are absolute, so we want the root file system.
          fs, _ = pa.fs.FileSystem.from_uri("/")
          ds = ray.data.read_binary_files(
              paths, filesystem=fs, parallelism=10
          )
          for i, item in enumerate(ds.iter_rows()):
              expected = open(paths[i], "rb").read()
              assert expected == item["bytes"]
  
imports: import os
  from io import BytesIO
  import pandas
  import pyarrow
  import pytest
  import requests
  import snappy
  import ray
  from ray.data.datasource import BaseFileMetadataProvider, FastFileMetadataProvider, Partitioning, PartitionStyle, PathPartitionFilter
  from ray.data.tests.conftest import *
  from ray.data.tests.mock_http_server import *
  from ray.data.tests.test_partitioning import PathPartitionEncoder
  from ray.data.tests.util import Counter, extract_values, gen_bin_files
  from ray.tests.conftest import *
label_desc: Use image node_id 4 for calling a global function with example usage: test_read_binary_files_with_fs(ray_start_regular_shared) without return types