warn on incompatible fsspec installation (#206)

* warn on incompatible fsspec installation

* make it more robust

* use once_per_args

Author: skshetry

setup.cfg

@@ -29,6 +29,7 @@ install_requires=
     funcy>=1.14
     fsspec>=2022.10.0
     typing-extensions>=3.7.4
+    packaging>=19
 
 [options.extras_require]
 tests =

src/dvc_objects/fs/base.py

@@ -22,7 +22,7 @@
 )
 
 from fsspec.asyn import get_loop
-from funcy import cached_property
+from funcy import cached_property, once_per_args
 
 from ..executors import ThreadPoolExecutor, batch_coros
 from .callbacks import DEFAULT_CALLBACK, Callback
@@ -58,6 +58,33 @@ def __init__(self, link: str, fs: "FileSystem", path: str) -> None:
         )
 
 
+@once_per_args
+def check_required_version(
+    pkg: str, dist: str = "dvc_objects", log_level=logging.WARNING
+):
+    from importlib import metadata
+
+    from packaging.requirements import InvalidRequirement, Requirement
+
+    try:
+        reqs = {
+            r.name: r.specifier for r in map(Requirement, metadata.requires(dist) or [])
+        }
+        version = metadata.version(pkg)
+    except (metadata.PackageNotFoundError, InvalidRequirement):
+        return
+
+    specifier = reqs.get(pkg)
+    if specifier and version and version not in specifier:
+        logger.log(
+            log_level,
+            "'%s%s' is required, but you have %r installed which is incompatible.",
+            pkg,
+            specifier,
+            version,
+        )
+
+
 class FileSystem:
     sep = "/"
 
@@ -142,6 +169,7 @@ def get_missing_deps(cls) -> List[str]:
     def _check_requires(self, **kwargs):
         from .scheme import Schemes
 
+        check_required_version(pkg="fsspec")
         missing = self.get_missing_deps()
         if not missing:
             return