code: def check_not_empty(check_str, error_message):
      if check_str == "":
          logging.fatal(error_message)
          exit(1)
  
file_path: flink/flink-python/pyflink/fn_execution/beam/beam_boot.py
imports: import argparse
  import logging
  import os
  import sys
  import grpc
  from apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2 import StartWorkerRequest
  from apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_grpc import BeamFnExternalWorkerPoolStub
  from apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2 import GetProvisionInfoRequest
  from apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc import ProvisionServiceStub
  from apache_beam.portability.api.org.apache.beam.model.pipeline.v1.endpoints_pb2 import ApiServiceDescriptor
  from google.protobuf import json_format, text_format
label_desc: Use image node_id 1 for calling a global function with example usage: check_not_empty(check_str, error_message) without return types