code: def test_schema_fields_int_without_external_table_async_should_execute_successfully(
      self, bq_hook, gcs_hook
  ):
      bq_hook.return_value.insert_job.return_value = MagicMock(
          job_id=pytest.real_job_id, error_result=False
      )
      bq_hook.return_value.generate_job_id.return_value = (
          pytest.real_job_id
      )
      bq_hook.return_value.split_tablename.return_value = (
          PROJECT_ID,
          DATASET,
          TABLE,
      )
      bq_hook.return_value.get_job.return_value.result.return_value = (
          "1",
      )
      gcs_hook.return_value.download.return_value = b"id,name\r\n1,Anna"
  
      operator = GCSToBigQueryOperator(
          task_id=TASK_ID,
          bucket=TEST_BUCKET,
          source_objects=TEST_SOURCE_OBJECTS,
          destination_project_dataset_table=TEST_EXPLICIT_DEST,
          write_disposition=WRITE_DISPOSITION,
          schema_fields=SCHEMA_FIELDS,
          max_id_key=MAX_ID_KEY,
          external_table=False,
          autodetect=True,
          deferrable=True,
          project_id=JOB_PROJECT_ID,
      )
  
      with pytest.raises(TaskDeferred):
          result = operator.execute(self.create_context(operator))
          assert result == "1"
  
          calls = [
              call(
                  configuration={
                      "load": dict(
                          autodetect=True,
                          createDisposition="CREATE_IF_NEEDED",
                          destinationTable={
                              "projectId": PROJECT_ID,
                              "datasetId": DATASET,
                              "tableId": TABLE,
                          },
                          destinationTableProperties={
                              "description": None,
                              "labels": None,
                          },
                          sourceFormat="CSV",
                          skipLeadingRows=None,
                          sourceUris=[
                              f"gs://{TEST_BUCKET}/{TEST_SOURCE_OBJECTS}"
                          ],
                          writeDisposition=WRITE_DISPOSITION,
                          ignoreUnknownValues=False,
                          allowQuotedNewlines=False,
                          encoding="UTF-8",
                      ),
                  },
                  project_id=JOB_PROJECT_ID,
                  location=None,
                  job_id=pytest.real_job_id,
                  timeout=None,
                  retry=DEFAULT_RETRY,
                  nowait=True,
              ),
              call(
                  configuration={
                      "query": {
                          "query": f"SELECT MAX({MAX_ID_KEY}) AS max_value FROM {TEST_EXPLICIT_DEST}",
                          "useLegacySql": False,
                          "schemaUpdateOptions": [],
                      }
                  },
                  project_id=JOB_PROJECT_ID,
              ),
          ]
  
          bq_hook.return_value.insert_job.assert_has_calls(calls)
  
imports: from __future__ import annotations
  import json
  from unittest import mock
  from unittest.mock import MagicMock, call
  import pytest
  from google.cloud.bigquery import DEFAULT_RETRY, Table
  from google.cloud.exceptions import Conflict
  from openlineage.client.facet import ColumnLineageDatasetFacet, ColumnLineageDatasetFacetFieldsAdditional, ColumnLineageDatasetFacetFieldsAdditionalInputFields, DocumentationDatasetFacet, ExternalQueryRunFacet, SchemaDatasetFacet, SchemaField, SymlinksDatasetFacet, SymlinksDatasetFacetIdentifiers
  from openlineage.client.run import Dataset
  from airflow.exceptions import AirflowException, TaskDeferred
  from airflow.models import DAG
  from airflow.models.dagrun import DagRun
  from airflow.models.taskinstance import TaskInstance
  from airflow.providers.google.cloud.transfers.gcs_to_bigquery import GCSToBigQueryOperator
  from airflow.providers.google.cloud.triggers.bigquery import BigQueryInsertJobTrigger
  from airflow.utils.timezone import datetime
  from airflow.utils.types import DagRunType
label_desc: Use image node_id 8 for calling the TestAsyncGCSToBigQueryOperator obj's underlying member method code with example usage: obj.test_schema_fields_int_without_external_table_async_should_execute_successfully(bq_hook, gcs_hook) without return types