code: def test_create_feature_store(
      feature_store_session,
      role,
      feature_group_name,
      offline_store_s3_uri,
      pandas_data_frame,
      record,
      create_table_ddl,
  ):
      feature_group = FeatureGroup(
          name=feature_group_name,
          sagemaker_session=feature_store_session,
      )
      feature_group.load_feature_definitions(
          data_frame=pandas_data_frame
      )
  
      with cleanup_feature_group(feature_group):
          output = feature_group.create(
              s3_uri=offline_store_s3_uri,
              record_identifier_name="feature1",
              event_time_feature_name="feature3",
              role_arn=role,
              enable_online_store=True,
          )
          _wait_for_feature_group_create(feature_group)
  
          resolved_output_s3_uri = (
              feature_group.describe()
              .get("OfflineStoreConfig")
              .get("S3StorageConfig")
              .get("ResolvedOutputS3Uri")
          )
          # Ingest data
          feature_group.put_record(record=record)
          ingestion_manager = feature_group.ingest(
              data_frame=pandas_data_frame, max_workers=3, wait=False
          )
          ingestion_manager.wait()
          assert 0 == len(ingestion_manager.failed_rows)
  
          # Query the integrated Glue table.
          athena_query = feature_group.athena_query()
          df = DataFrame()
          with timeout(minutes=10):
              while df.shape[0] < 11:
                  athena_query.run(
                      query_string=f'SELECT * FROM "{athena_query.table_name}"',
                      output_location=f"{offline_store_s3_uri}/query_results",
                  )
                  athena_query.wait()
                  assert (
                      "SUCCEEDED"
                      == athena_query.get_query_execution()
                      .get("QueryExecution")
                      .get("Status")
                      .get("State")
                  )
                  df = athena_query.as_dataframe()
                  print(f"Found {df.shape[0]} records.")
                  time.sleep(60)
  
          assert df.shape[0] == 11
          nans = pd.isna(
              df.loc[df["feature1"].isin([5, 6, 7, 8, 9])]["feature4"]
          )
          for is_na in nans.items():
              assert is_na
          assert (
              create_table_ddl.format(
                  feature_group_name=feature_group_name,
                  region=feature_store_session.boto_session.region_name,
                  account=feature_store_session.account_id(),
                  resolved_output_s3_uri=resolved_output_s3_uri,
              )
              == feature_group.as_hive_ddl()
          )
      assert output["FeatureGroupArn"].endswith(
          f"feature-group/{feature_group_name}"
      )
  
imports: from __future__ import absolute_import
  import datetime
  import json
  import time
  import dateutil.parser
  from contextlib import contextmanager
  import boto3
  import numpy
  import pandas
  import pytest
  from pandas import DataFrame
  from sagemaker.feature_store.feature_utils import get_feature_group_as_dataframe
  from sagemaker.feature_store.feature_definition import FractionalFeatureDefinition, StringFeatureDefinition, ListCollectionType
  from sagemaker.feature_store.feature_group import FeatureGroup
  from sagemaker.feature_store.feature_store import FeatureStore
  from sagemaker.feature_store.inputs import FeatureValue, FeatureParameter, TableFormatEnum, Filter, ResourceEnum, Identifier, DeletionModeEnum, TtlDuration, OnlineStoreConfigUpdate, OnlineStoreStorageTypeEnum
  from sagemaker.feature_store.dataset_builder import JoinTypeEnum
  from sagemaker.session import get_execution_role, Session
  from tests.integ.timeout import timeout
  from urllib.parse import urlparse
label_desc: Use image node_id 16 for calling a global function with example usage: test_create_feature_store(feature_store_session, role, feature_group_name, offline_store_s3_uri, pandas_data_frame, record, create_table_ddl) without return types