code: def forward_stream(src_fd, dst_stream):
      with os.fdopen(src_fd, "r") as src:
          while True:
              line = src.readline()
              if not line:
                  break
              dst_stream.write(line)
              dst_stream.flush()
  
file_path: bluefog/bluefog/run/horovodrun/common/util/safe_shell_exec.py
imports: import os
  import psutil
  import signal
  import subprocess
  import sys
  import threading
  import time
label_desc: Use image node_id 2 for calling a global function with example usage: forward_stream(src_fd, dst_stream) without return types