code: def input_loader(feature_group_as_spark_df, s3_uri_as_spark_df):
      input_loader = Mock(InputLoader)
      input_loader.load_from_s3.return_value = s3_uri_as_spark_df
      input_loader.load_from_feature_group.return_value = (
          feature_group_as_spark_df
      )
  
      return input_loader
  
imports: from __future__ import absolute_import
  import pytest
  import test_data_helpers
  from mock import Mock, patch
  from pyspark.sql import DataFrame, SparkSession
  from sagemaker.feature_store.feature_processor._input_loader import InputLoader
  from sagemaker.feature_store.feature_processor._params_loader import ParamsLoader
  from sagemaker.feature_store.feature_processor._spark_factory import SparkSessionFactory
  from sagemaker.feature_store.feature_processor._udf_arg_provider import SparkArgProvider
  from sagemaker.feature_store.feature_processor._data_source import PySparkDataSource
label_desc: Use image node_id 5 for calling a global function with example usage: input_loader(feature_group_as_spark_df, s3_uri_as_spark_df) and returns: input_loader