code: def _get_datastore_storage_impl(ds_type):
      storage_impl = [d for d in DATASTORES if d.TYPE == ds_type]
      if len(storage_impl) == 0:
          raise FileCacheException(
              "Datastore %s was not found" % ds_type
          )
      return storage_impl[0]
  
imports: from __future__ import print_function
  from collections import OrderedDict
  import os
  import sys
  import time
  from tempfile import NamedTemporaryFile
  from hashlib import sha1
  from metaflow.datastore import FlowDataStore
  from metaflow.datastore.content_addressed_store import BlobCache
  from metaflow.exception import MetaflowException
  from metaflow.metaflow_config import CLIENT_CACHE_PATH, CLIENT_CACHE_MAX_SIZE, CLIENT_CACHE_MAX_FLOWDATASTORE_COUNT, CLIENT_CACHE_MAX_TASKDATASTORE_COUNT
  from metaflow.plugins import DATASTORES
label_desc: Use image node_id 21 for calling the FileCache obj's underlying member method code with example usage: obj._get_datastore_storage_impl(ds_type) and returns: storage_impl