code: def __init__(self, sock):
      self._sock = sock
      self._sock.settimeout(None)  # Make the socket blocking
      self._is_closed = False
  
file_path: metaflow/metaflow/plugins/env_escape/communication/socket_bytestream.py
imports: import errno
  import socket
  import sys
  from .bytestream import ByteStream
  from .utils import __try_op__
label_desc: Use image node_id 3 to create a new SocketByteStream object from inherited base classes: ByteStream with example: obj = SocketByteStream(sock)