lint

fsspec/caching.py

@@ -7,9 +7,9 @@
 import os
 import threading
 import warnings
+from concurrent.futures import Future, ThreadPoolExecutor
 from itertools import groupby
 from operator import itemgetter
-from concurrent.futures import Future, ThreadPoolExecutor
 from typing import (
     TYPE_CHECKING,
     Any,

fsspec/implementations/asyn_wrapper.py

@@ -1,6 +1,7 @@
 import asyncio
-import inspect
 import functools
+import inspect
+
 from fsspec.asyn import AsyncFileSystem
 
 

fsspec/implementations/reference.py

@@ -176,7 +176,7 @@ def open_refs(field, record):
             try:
                 df = self.pd.read_parquet(data, engine=self.engine)
                 refs = {c: df[c].to_numpy() for c in df.columns}
-            except IOError:
+            except OSError:
                 refs = None
             return refs
 

fsspec/implementations/tests/test_asyn_wrapper.py

@@ -1,10 +1,12 @@
 import asyncio
-import pytest
 import os
 
+import pytest
+
 import fsspec
 from fsspec.implementations.asyn_wrapper import AsyncFileSystemWrapper
 from fsspec.implementations.local import LocalFileSystem
+
 from .test_local import csv_files, filetexts