release: temporarily unpin kombu to unblock conda release

Author: pmrowla

setup.cfg

@@ -24,8 +24,8 @@ package_dir=
     =src
 packages = find:
 install_requires=
-    kombu>=5.3.0a1
-    celery>=5.3.0a1,<6
+    celery>=5.2.0,<6
+    kombu
     funcy>=1.17
     shortuuid>=1.0.8
     pywin32>=225; sys_platform == 'win32'
@@ -39,6 +39,7 @@ docs =
     mkdocstrings-python==0.7.0
 tests =
     flaky==3.7.0
+    kombu>=5.3.0a1
     pytest==7.1.2
     pytest-sugar==0.9.4
     pytest-cov==3.0.0

src/dvc_task/app/filesystem.py

@@ -8,11 +8,24 @@
 from kombu.utils.encoding import bytes_to_str
 from kombu.utils.json import loads
 
+from ..exceptions import DvcTaskError
 from ..utils import makedirs, remove, unc_path
 
 logger = logging.getLogger(__name__)
 
 
+def _check_kombu_version():
+    # pylint: disable=import-outside-toplevel
+    from kombu import VERSION, __version__
+
+    # FSApp requires kombu >= 5.3.0
+    if VERSION.major < 5 or (VERSION.major == 5 and VERSION.minor < 3):
+        raise DvcTaskError(
+            f"Unsupported Kombu version '{__version__}' found. "
+            "dvc-task FSApp requires Kombu >=5.3.0."
+        )
+
+
 def _get_fs_config(
     wdir: str,
     mkdir: bool = False,
@@ -78,6 +91,7 @@ def __init__(
 
         Additional arguments will be passed into the Celery constructor.
         """
+        _check_kombu_version()
         super().__init__(*args, **kwargs)
         self.wdir = wdir or os.getcwd()
         self.conf.update(