code: def test_load_from_iceberg_table(
      mock_get_filter_condition,
      condition,
      input_loader,
      spark_session,
      spark_session_factory,
      mock_data_frame,
  ):
      iceberg_table_data_source = IcebergTableDataSource(
          warehouse_s3_uri="s3://bucket/prefix/",
          catalog="Catalog",
          database="Database",
          table="Table",
      )
      mock_get_filter_condition.return_value = condition
  
      input_loader.load_from_iceberg_table(
          iceberg_table_data_source, "event_time", "start", "end"
      )
      spark_session_factory.get_spark_session_with_iceberg_config.assert_called_with(
          "s3://bucket/prefix/", "catalog"
      )
      spark_session.table.assert_called_with("catalog.database.table")
      mock_get_filter_condition.assert_called_with(
          "event_time", "start", "end"
      )
  
      if condition:
          mock_data_frame.filter.assert_called_with(condition)
      else:
          mock_data_frame.filter.assert_not_called()
  
imports: from __future__ import absolute_import
  import pytest
  import test_data_helpers
  from mock import Mock, patch, call
  from pyspark.sql import SparkSession, DataFrame
  from sagemaker.feature_store.feature_processor._data_source import CSVDataSource, FeatureGroupDataSource, ParquetDataSource, IcebergTableDataSource
  from sagemaker.feature_store.feature_processor._input_loader import SparkDataFrameInputLoader
  from sagemaker.feature_store.feature_processor._spark_factory import SparkSessionFactory
  from sagemaker.feature_store.feature_processor._env import EnvironmentHelper
  from sagemaker.session import Session
label_desc: Use image node_id 11 for calling a global function with example usage: test_load_from_iceberg_table(mock_get_filter_condition, condition, input_loader, spark_session, spark_session_factory, mock_data_frame) without return types