code: def print_to_logging(logging_func, msg, *args, **kwargs):
      if msg != "\n":
          logging_func(msg, *args, **kwargs)
  
file_path: flink/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py
imports: import sys
  import pyflink.fn_execution.beam.beam_operations
  import pyflink.fn_execution.beam.beam_coders
  import apache_beam.runners.worker.sdk_worker_main
  from apache_beam.runners.worker import sdk_worker
label_desc: Use image node_id 1 for calling a global function with example usage: print_to_logging(logging_func, msg) without return types