code: def _MockReadFromBigQuery(
      pipeline, query, big_query_custom_config=None
  ):
      del query, big_query_custom_config  # Unused arg
      mock_query_results = []
      for i in range(10000):
          mock_query_result = {
              "i": None if random.randrange(10) == 0 else i,
              "f": None if random.randrange(10) == 0 else float(i),
              "s": None if random.randrange(10) == 0 else str(i),
          }
          mock_query_results.append(mock_query_result)
      return pipeline | beam.Create(mock_query_results)
  
imports: import json
  import os
  import random
  from unittest import mock
  import apache_beam
  from apache_beam.testing import util
  from google.cloud import bigquery
  import tensorflow
  from tfx.dsl.components.base import base_beam_executor
  from tfx.dsl.io import fileio
  from tfx.extensions.google_cloud_big_query import utils
  from tfx.extensions.google_cloud_big_query.example_gen import executor
  from tfx.proto import example_gen_pb2
  from tfx.types import artifact_utils
  from tfx.types import standard_artifacts
  from tfx.utils import proto_utils
label_desc: Use image node_id 1 for calling a global function with example usage: _MockReadFromBigQuery(pipeline, query, big_query_custom_config) and returns: unknown