code: def beamformit_worker(
      beamformit_tool, config_file, source_dir, channel_scp, output_root
  ):
      f = open(channel_scp)
      for line in f:
          show_id = line.split(" ")[0]
          store_dir = os.path.join(
              "/", *line.split(" ")[1].split("/")[:-1]
          )
          print("*" * 50)
          print(store_dir)
          print(show_id)
          print("*" * 50)
          if not os.path.exists(store_dir):
              os.makedirs(store_dir, exist_ok=True)
          cmd = "{} -s {} -c {} --config_file {} -source_dir {} --result_dir {}".format(
              beamformit_tool,
              show_id,
              channel_scp,
              config_file,
              source_dir,
              store_dir,
          )
          os.system(cmd)
      f.close()
      return
  
label_desc: Use image node_id 1 for calling a global function with example usage: beamformit_worker(beamformit_tool, config_file, source_dir, channel_scp, output_root) without return types