code: def generate_data_ingestion_flow_from_athena_dataset_definition(
      input_name: str,
      athena_dataset_definition: AthenaDatasetDefinition,
      operator_version: str = "0.1",
      schema: Dict = None,
  ):
      """Generate the data ingestion only flow from athena input
  
      Args:
          input_name (str): the name of the input to flow source node
          athena_dataset_definition (AthenaDatasetDefinition): athena input to flow source node
          operator_version: (str): the version of the operator
          schema: (typing.Dict): the schema for the data to be ingested
      Returns:
          dict (typing.Dict): A flow only conduct data ingestion with 1-1 mapping
          output_name (str): The output name used to configure
          `sagemaker.processing.FeatureStoreOutput`
      """
      source_node = {
          "node_id": str(uuid4()),
          "type": "SOURCE",
          "inputs": [],
          "outputs": [{"name": "default"}],
          "operator": f"sagemaker.athena_source_{operator_version}",
          "parameters": {
              "dataset_definition": {
                  "datasetSourceType": "Athena",
                  "name": input_name,
                  "catalogName": athena_dataset_definition.catalog,
                  "databaseName": athena_dataset_definition.database,
                  "queryString": athena_dataset_definition.query_string,
                  "s3OutputLocation": athena_dataset_definition.output_s3_uri,
                  "outputFormat": athena_dataset_definition.output_format,
              }
          },
      }
  
      output_node = _get_output_node(
          source_node["node_id"], operator_version, schema
      )
  
      flow = {
          "metadata": {"version": 1, "disable_limits": False},
          "nodes": [source_node, output_node],
      }
  
      return flow, f'{output_node["node_id"]}.default'
  
imports: from __future__ import absolute_import
  from typing import Dict
  from uuid import uuid4
  from sagemaker.dataset_definition.inputs import RedshiftDatasetDefinition, AthenaDatasetDefinition
label_desc: Use image node_id 2 for calling a global function with example usage: generate_data_ingestion_flow_from_athena_dataset_definition(input_name, athena_dataset_definition, operator_version, schema) and returns: flow,  output_node, str