code: def _splits_dir(self, snapshot_path, stream_idx=0, worker=0):
      stream_name = f"stream_{stream_idx}"
      self._make_stream_dir(snapshot_path, stream_name, worker=worker)
      return os.path.join(
          snapshot_path, "streams", stream_name, "splits"
      )
  
imports: import collections
  import os
  import pathlib
  import time
  from absl.testing import parameterized
  from tensorflow.python.data.experimental.kernel_tests.service import test_base
  from tensorflow.python.data.experimental.ops import distributed_save_op
  from tensorflow.python.data.experimental.service import _pywrap_snapshot_utils
  from tensorflow.python.data.kernel_tests import test_base
  from tensorflow.python.data.ops import dataset_ops
  from tensorflow.python.framework import combinations
  from tensorflow.python.framework import errors
  from tensorflow.python.platform import test
label_desc: Use image node_id 20 for calling the SnapshotFtTest obj's underlying member method code with example usage: obj._splits_dir(snapshot_path, stream_idx, worker) and returns: os