code: def blocking_writable_stream_to_async(
      thread_pool: ThreadPoolExecutor, f: BinaryIO
  ) -> _WritableStreamFromBlocking:
      return _WritableStreamFromBlocking(thread_pool, f)
  
imports: from typing import BinaryIO, List, Optional, Tuple, Type
  from types import TracebackType
  import abc
  import io
  import os
  import sys
  from concurrent.futures import ThreadPoolExecutor
  import janus
  from hailtop.utils import blocking_to_async
  from .exceptions import UnexpectedEOFError
label_desc: Use image node_id 2 for calling a global function with example usage: blocking_writable_stream_to_async(thread_pool, f) and returns: _WritableStreamFromBlocking