code: def extract_custom_driver_spec(
      deployment_config: local_deployment_config_pb2.LocalDeploymentConfig,
      node_id: str,
  ) -> Optional[message.Message]:
      return _unwrap_executable_spec(
          deployment_config.custom_driver_specs.get(node_id)
      )
  
file_path: tfx/tfx/orchestration/local/runner_utils.py
imports: from typing import Optional
  from absl import logging
  from tfx.proto.orchestration import local_deployment_config_pb2
  from tfx.proto.orchestration import metadata_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from google.protobuf import any_pb2
  from google.protobuf import message
label_desc: Use image node_id 7 for calling a global function with example usage: extract_custom_driver_spec(deployment_config, node_id) and returns: _unwrap_executable_spec