code: def test_numpy_write(
      ray_start_regular_shared, fs, data_path, endpoint_url
  ):
      ds = ray.data.range_tensor(10, parallelism=2)
      ds._set_uuid("data")
      ds.write_numpy(data_path, filesystem=fs, column="data")
      file_path1 = os.path.join(data_path, "data_000000_000000.npy")
      file_path2 = os.path.join(data_path, "data_000001_000000.npy")
      if endpoint_url is None:
          arr1 = np.load(file_path1)
          arr2 = np.load(file_path2)
      else:
          from s3fs.core import S3FileSystem
  
          s3 = S3FileSystem(
              client_kwargs={"endpoint_url": endpoint_url}
          )
          arr1 = np.load(s3.open(file_path1))
          arr2 = np.load(s3.open(file_path2))
      assert ds.count() == 10
      assert len(arr1) == 5
      assert len(arr2) == 5
      assert arr1.sum() == 10
      assert arr2.sum() == 35
      np.testing.assert_equal(
          extract_values("data", ds.take(1)), [np.array([0])]
      )
  
imports: import os
  import numpy
  import pandas
  import pyarrow
  import pytest
  from pytest_lazyfixture import lazy_fixture
  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
  from ray.tests.conftest import *
label_desc: Use image node_id 10 for calling a global function with example usage: test_numpy_write(ray_start_regular_shared, fs, data_path, endpoint_url) without return types