Remove more GCSStore code

Author: tjcrone

zarr/storage.py

@@ -1903,13 +1903,6 @@ def _append_path_to_prefix(path, prefix):
                      normalize_storage_path(path)])
 
 
-def atexit_rmgcspath(bucket, path):
-    from google.cloud import storage
-    client = storage.Client()
-    bucket = client.get_bucket(bucket)
-    bucket.delete_blobs(bucket.list_blobs(prefix=path))
-
-
 class ABSStore(MutableMapping):
     """Storage class using Azure Blob Storage (ABS).
 

zarr/tests/test_core.py

@@ -7,7 +7,7 @@
 import pickle
 import os
 import warnings
-import uuid
+
 
 import numpy as np
 from numpy.testing import assert_array_equal, assert_array_almost_equal
@@ -16,7 +16,7 @@
 
 from zarr.storage import (DirectoryStore, init_array, init_group, NestedDirectoryStore,
                           DBMStore, LMDBStore, atexit_rmtree, atexit_rmglob,
-                          LRUStoreCache, GCSStore, atexit_rmgcspath)
+                          LRUStoreCache)
 from zarr.core import Array
 from zarr.errors import PermissionError
 from zarr.compat import PY2, text_type, binary_type
@@ -1698,25 +1698,3 @@ def create_array(read_only=False, **kwargs):
         init_array(store, **kwargs)
         return Array(store, read_only=read_only, cache_metadata=cache_metadata,
                      cache_attrs=cache_attrs)
-
-
-try:
-    from google.cloud import storage as gcstorage
-except ImportError:  # pragma: no cover
-    gcstorage = None
-
-
-@unittest.skipIf(gcstorage is None, 'google-cloud-storage is not installed')
-class TestGCSArray(TestArray):
-
-    def create_array(self, read_only=False, **kwargs):
-        bucket = 'zarr-test'
-        prefix = uuid.uuid4()
-        atexit.register(atexit_rmgcspath, bucket, prefix)
-        store = GCSStore(bucket, prefix)
-        cache_metadata = kwargs.pop('cache_metadata', True)
-        cache_attrs = kwargs.pop('cache_attrs', True)
-        kwargs.setdefault('compressor', Zlib(1))
-        init_array(store, **kwargs)
-        return Array(store, read_only=read_only, cache_metadata=cache_metadata,
-                     cache_attrs=cache_attrs)

zarr/tests/test_storage.py

@@ -8,7 +8,6 @@
 import array
 import shutil
 import os
-import uuid
 
 
 import numpy as np
@@ -20,8 +19,7 @@
                           DirectoryStore, ZipStore, init_group, group_meta_key,
                           getsize, migrate_1to2, TempStore, atexit_rmtree,
                           NestedDirectoryStore, default_compressor, DBMStore,
-                          LMDBStore, atexit_rmglob, LRUStoreCache, GCSStore,
-                          atexit_rmgcspath)
+                          LMDBStore, atexit_rmglob, LRUStoreCache)
 from zarr.meta import (decode_array_metadata, encode_array_metadata, ZARR_FORMAT,
                        decode_group_metadata, encode_group_metadata)
 from zarr.compat import PY2
@@ -1237,29 +1235,3 @@ def test_format_compatibility():
             else:
                 assert compressor.codec_id == z.compressor.codec_id
                 assert compressor.get_config() == z.compressor.get_config()
-
-
-try:
-    from google.cloud import storage as gcstorage
-    # cleanup function
-
-except ImportError:  # pragma: no cover
-    gcstorage = None
-
-
-@unittest.skipIf(gcstorage is None, 'google-cloud-storage is not installed')
-class TestGCSStore(StoreTests, unittest.TestCase):
-
-    def create_store(self):
-        # would need to be replaced with a dedicated test bucket
-        bucket = 'zarr-test'
-        prefix = uuid.uuid4()
-        atexit.register(atexit_rmgcspath, bucket, prefix)
-        store = GCSStore(bucket, prefix)
-        return store
-
-    def test_context_manager(self):
-        with self.create_store() as store:
-            store['foo'] = b'bar'
-            store['baz'] = b'qux'
-            assert 2 == len(store)