code: def _write_test_execution(mlmd_handle):
      execution_type = metadata_store_pb2.ExecutionType(
          name="foo", version="bar"
      )
      execution_type_id = mlmd_handle.store.put_execution_type(
          execution_type
      )
      [execution_id] = mlmd_handle.store.put_executions(
          [metadata_store_pb2.Execution(type_id=execution_type_id)]
      )
      [execution] = mlmd_handle.store.get_executions_by_id(
          [execution_id]
      )
      return execution
  
imports: from concurrent import futures
  import os
  import threading
  import tensorflow
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.core import mlmd_state
  from tfx.orchestration.experimental.core import test_utils
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 2 for calling a global function with example usage: _write_test_execution(mlmd_handle) and returns: execution