code: def forward_stream(
      src_stream: io.RawIOBase, dst_stream: BinaryIO, rank: str
  ) -> None:
      for line in read_newlines_or_carriage_returns(src_stream):
          os.write(
              dst_stream.fileno(),
              f"[rank={rank}] {line}".encode("utf8"),
          )
  
file_path: determined/harness/determined/launch/wrap_rank.py
imports: import argparse
  import contextlib
  import io
  import os
  import re
  import subprocess
  import sys
  import threading
  from typing import BinaryIO, Iterator, List
  import determined
  from determined import constants
label_desc: Use image node_id 2 for calling a global function with example usage: forward_stream(src_stream, dst_stream, rank) without return types