• Tal Sh's avatar
    Removed excess copying when fetching data from ZMQ (#746) · 3dd7171d
    Tal Sh authored
    * Removed excess copying when fetching data from ZMQ
    
    The `.bytes` explicitly triggers a copy in order to create a Python `bytes` object. This isn't necessary for pyarrow deserialization.
    
    * Remove all the `.bytes`!
    
    * Fixed crash when deleting a MultiThreadPrefetchData instance when `reset_state()` was not called
    3dd7171d
parallel_map.py 13.5 KB