code: def test_operator_openlineage_data(self, mock_conn, mock_region_name):
      mock_region_name.return_value = "eu-west-1"
  
      def mock_get_table_metadata(CatalogName, DatabaseName, TableName):
          with open(
              "tests/providers/amazon/aws/operators/athena_metadata.json"
          ) as f:
              return json.load(f)[TableName]
  
      mock_conn.return_value.get_table_metadata = (
          mock_get_table_metadata
      )
  
      op = AthenaOperator(
          task_id="test_athena_openlineage",
          query="INSERT INTO TEST_TABLE SELECT CUSTOMER_EMAIL FROM DISCOUNTS",
          database="TEST_DATABASE",
          output_location="s3://test_s3_bucket/",
          client_request_token="eac427d0-1c6d-4dfb-96aa-2835d3ac6595",
          sleep_time=0,
          max_polling_attempts=3,
          dag=self.dag,
      )
  
      expected_lineage = OperatorLineage(
          inputs=[
              Dataset(
                  namespace="awsathena://athena.eu-west-1.amazonaws.com",
                  name="AwsDataCatalog.TEST_DATABASE.DISCOUNTS",
                  facets={
                      "symlinks": SymlinksDatasetFacet(
                          identifiers=[
                              SymlinksDatasetFacetIdentifiers(
                                  namespace="s3://bucket",
                                  name="/discount/data/path/",
                                  type="TABLE",
                              )
                          ],
                      ),
                      "schema": SchemaDatasetFacet(
                          fields=[
                              SchemaField(
                                  name="ID",
                                  type="int",
                                  description="from deserializer",
                              ),
                              SchemaField(
                                  name="AMOUNT_OFF",
                                  type="int",
                                  description="from deserializer",
                              ),
                              SchemaField(
                                  name="CUSTOMER_EMAIL",
                                  type="varchar",
                                  description="from deserializer",
                              ),
                              SchemaField(
                                  name="STARTS_ON",
                                  type="timestamp",
                                  description="from deserializer",
                              ),
                              SchemaField(
                                  name="ENDS_ON",
                                  type="timestamp",
                                  description="from deserializer",
                              ),
                          ],
                      ),
                  },
              )
          ],
          outputs=[
              Dataset(
                  namespace="awsathena://athena.eu-west-1.amazonaws.com",
                  name="AwsDataCatalog.TEST_DATABASE.TEST_TABLE",
                  facets={
                      "symlinks": SymlinksDatasetFacet(
                          identifiers=[
                              SymlinksDatasetFacetIdentifiers(
                                  namespace="s3://bucket",
                                  name="/data/test_table/data/path",
                                  type="TABLE",
                              )
                          ],
                      ),
                      "schema": SchemaDatasetFacet(
                          fields=[
                              SchemaField(
                                  name="column",
                                  type="string",
                                  description="from deserializer",
                              )
                          ],
                      ),
                  },
              ),
              Dataset(namespace="s3://test_s3_bucket", name="/"),
          ],
          job_facets={
              "sql": SqlJobFacet(
                  query="INSERT INTO TEST_TABLE SELECT CUSTOMER_EMAIL FROM DISCOUNTS",
              )
          },
      )
      assert op.get_openlineage_facets_on_start() == expected_lineage
  
imports: from __future__ import annotations
  import json
  from unittest import mock
  import pytest
  from openlineage.client.facet import SchemaDatasetFacet, SchemaField, SqlJobFacet, SymlinksDatasetFacet, SymlinksDatasetFacetIdentifiers
  from openlineage.client.run import Dataset
  from airflow.exceptions import TaskDeferred
  from airflow.models import DAG, DagRun, TaskInstance
  from airflow.providers.amazon.aws.hooks.athena import AthenaHook
  from airflow.providers.amazon.aws.operators.athena import AthenaOperator
  from airflow.providers.amazon.aws.triggers.athena import AthenaTrigger
  from airflow.providers.openlineage.extractors import OperatorLineage
  from airflow.utils import timezone
  from airflow.utils.timezone import datetime
label_desc: Use image node_id 13 for calling the TestAthenaOperator obj's underlying member method code with example usage: obj.test_operator_openlineage_data(mock_conn, mock_region_name) and returns: json