Merge pull request #2304 from activeloopai/fy_disable_async

Temporarily disable S3 async flush
activeloopai · Apr 20, 2023 · 21a5c24 · 21a5c24
2 parents eebde70 + 9952967
commit 21a5c24
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/deeplake/core/storage/lru_cache.py b/deeplake/core/storage/lru_cache.py
@@ -57,11 +57,13 @@ def __init__(
 
         self.cache_used = 0
         self.deeplake_objects: Dict[str, DeepLakeMemoryObject] = {}
-        self.use_async = (
-            next_storage.async_supported()
-            if next_storage
-            else False and sys.version_info >= (3, 7) and sys.platform != "win32"
-        )
+        # TODO: BRING THIS BACK AFTER ASYNC IS FIXED
+        # self.use_async = (
+        #     next_storage.async_supported()
+        #     if next_storage
+        #     else False and sys.version_info >= (3, 7) and sys.platform != "win32"
+        # )
+        self.use_async = False
 
     def register_deeplake_object(self, path: str, obj: DeepLakeMemoryObject):
         """Registers a new object in the cache."""