code: def get_log_tailer(log_url, datastore_type):
      if datastore_type == "s3":
          from metaflow.plugins.datatools.s3.s3tail import S3Tail
  
          return S3Tail(log_url)
      elif datastore_type == "azure":
          from metaflow.plugins.azure.azure_tail import AzureTail
  
          return AzureTail(log_url)
      elif datastore_type == "gs":
          from metaflow.plugins.gcp.gs_tail import GSTail
  
          return GSTail(log_url)
      else:
          raise MetaflowInternalError(
              "Log tailing implementation missing for datastore type %s"
              % (datastore_type,)
          )
  
file_path: metaflow/metaflow/mflog/__init__.py
imports: import math
  import time
  from .mflog import refine, set_should_persist
  from metaflow.util import to_unicode
  from metaflow.exception import MetaflowInternalError
label_desc: Use image node_id 5 for calling a global function with example usage: get_log_tailer(log_url, datastore_type) and returns: S3Tail, AzureTail, GSTail