code: def _MockReadFromBigQuery(pipeline, query):
      del query  # Unused arg
      mock_query_results = [
          {
              "context_feature_1": 1,
              "context_feature_2": 1,
              "feature_id_1": 1,
              "feature_id_2": 1.0,
              "feature_id_3": "one",
          },
          {
              "context_feature_1": 1,
              "feature_id_3": "two",
              "feature_id_1": 2,
              "context_feature_2": 2,
              "feature_id_2": 2.0,
          },
          {
              "context_feature_1": 2,
              "context_feature_2": 1,
              "feature_id_1": 3,
              "feature_id_2": 3.0,
              "feature_id_3": "three",
          },
          {
              "context_feature_1": 2,
              "context_feature_2": 1,
              "feature_id_1": 4,
              "feature_id_2": 4.0,
              "feature_id_3": ["four"],
          },
          {
              "context_feature_1": 3,
              "context_feature_2": None,
              "feature_id_1": 5,
              "feature_id_2": [5.0],
              "feature_id_3": "five",
          },
          {
              "context_feature_1": 4,
              "context_feature_2": None,
              "feature_id_1": [5],
              "feature_id_2": None,
              "feature_id_3": "five",
          },
      ]
      return pipeline | beam.Create(mock_query_results)
  
file_path: tfx/tfx/extensions/google_cloud_big_query/experimental/elwc_example_gen/component/executor_test.py
imports: from unittest import mock
  import apache_beam
  from apache_beam.testing import util
  from google.cloud import bigquery
  import tensorflow
  from tfx.extensions.google_cloud_big_query import utils
  from tfx.extensions.google_cloud_big_query.experimental.elwc_example_gen.component import executor
  from tfx.extensions.google_cloud_big_query.experimental.elwc_example_gen.proto import elwc_config_pb2
  from tfx.proto import example_gen_pb2
  from google.protobuf import json_format
  from google.protobuf import text_format
  from tensorflow_serving.apis import input_pb2
label_desc: Use image node_id 1 for calling a global function with example usage: _MockReadFromBigQuery(pipeline, query) and returns: unknown