chore(deps): update dependency google-cloud-storage to v1.28.1 [(#3785)](#3785)

* chore(deps): update dependency google-cloud-storage to v1.28.1

* [asset] testing: use uuid instead of time

Co-authored-by: Takashi Matsuo <[email protected]>

Author: 2 people

asset/snippets/snippets/quickstart_batchgetassetshistory_test.py

@@ -15,15 +15,17 @@
 # limitations under the License.
 
 import os
-import time
+import uuid
 
+import backoff
+from google.api_core.exceptions import InvalidArgument
 from google.cloud import storage
 import pytest
 
 import quickstart_batchgetassetshistory
 
 PROJECT = os.environ['GCLOUD_PROJECT']
-BUCKET = 'assets-{}'.format(int(time.time()))
+BUCKET = 'assets-{}'.format(uuid.uuid4().hex)
 
 
 @pytest.fixture(scope='module')
@@ -47,12 +49,15 @@ def asset_bucket(storage_client):
 def test_batch_get_assets_history(asset_bucket, capsys):
     bucket_asset_name = '//storage.googleapis.com/{}'.format(BUCKET)
     asset_names = [bucket_asset_name, ]
-    # There's some delay between bucket creation and when it's reflected in the
-    # backend.
-    time.sleep(15)
-    quickstart_batchgetassetshistory.batch_get_assets_history(
-        PROJECT, asset_names)
-    out, _ = capsys.readouterr()
-
-    if not out:
+
+    @backoff.on_exception(
+        backoff.expo, (AssertionError, InvalidArgument), max_time=30
+    )
+    def eventually_consistent_test():
+        quickstart_batchgetassetshistory.batch_get_assets_history(
+            PROJECT, asset_names)
+        out, _ = capsys.readouterr()
+
         assert bucket_asset_name in out
+
+    eventually_consistent_test()

asset/snippets/snippets/quickstart_createfeed_test.py

@@ -16,7 +16,7 @@
 
 import json
 import os
-import time
+import uuid
 
 from google.cloud import pubsub_v1
 from google.cloud import resource_manager
@@ -27,9 +27,9 @@
 json_data = open(os.environ["GOOGLE_APPLICATION_CREDENTIALS"]).read()
 data = json.loads(json_data)
 PROJECT = data['project_id']
-ASSET_NAME = 'assets-{}'.format(int(time.time()))
-FEED_ID = 'feed-{}'.format(int(time.time()))
-TOPIC = 'topic-{}'.format(int(time.time()))
+ASSET_NAME = 'assets-{}'.format(uuid.uuid4().hex)
+FEED_ID = 'feed-{}'.format(uuid.uuid4().hex)
+TOPIC = 'topic-{}'.format(uuid.uuid4().hex)
 
 
 def test_create_feed(capsys):

asset/snippets/snippets/quickstart_deletefeed_test.py

@@ -15,7 +15,7 @@
 # limitations under the License.
 
 import os
-import time
+import uuid
 
 from google.cloud import pubsub_v1
 from google.cloud import resource_manager
@@ -24,9 +24,9 @@
 import quickstart_deletefeed
 
 PROJECT = os.environ['GCLOUD_PROJECT']
-ASSET_NAME = 'assets-{}'.format(int(time.time()))
-FEED_ID = 'feed-{}'.format(int(time.time()))
-TOPIC = 'topic-{}'.format(int(time.time()))
+ASSET_NAME = 'assets-{}'.format(uuid.uuid4().hex)
+FEED_ID = 'feed-{}'.format(uuid.uuid4().hex)
+TOPIC = 'topic-{}'.format(uuid.uuid4().hex)
 
 
 def test_delete_feed(capsys):

asset/snippets/snippets/quickstart_exportassets_test.py

@@ -15,15 +15,15 @@
 # limitations under the License.
 
 import os
-import time
+import uuid
 
 from google.cloud import storage
 import pytest
 
 import quickstart_exportassets
 
 PROJECT = os.environ['GCLOUD_PROJECT']
-BUCKET = 'assets-{}'.format(int(time.time()))
+BUCKET = 'assets-{}'.format(uuid.uuid4().hex)
 
 
 @pytest.fixture(scope='module')

asset/snippets/snippets/quickstart_getfeed_test.py

@@ -15,7 +15,7 @@
 # limitations under the License.
 
 import os
-import time
+import uuid
 
 from google.cloud import pubsub_v1
 from google.cloud import resource_manager
@@ -25,9 +25,9 @@
 import quickstart_getfeed
 
 PROJECT = os.environ['GCLOUD_PROJECT']
-ASSET_NAME = 'assets-{}'.format(int(time.time()))
-FEED_ID = 'feed-{}'.format(int(time.time()))
-TOPIC = 'topic-{}'.format(int(time.time()))
+ASSET_NAME = 'assets-{}'.format(uuid.uuid4().hex)
+FEED_ID = 'feed-{}'.format(uuid.uuid4().hex)
+TOPIC = 'topic-{}'.format(uuid.uuid4().hex)
 
 
 def test_get_feed(capsys):

asset/snippets/snippets/quickstart_updatefeed_test.py

@@ -15,7 +15,7 @@
 # limitations under the License.
 
 import os
-import time
+import uuid
 
 from google.cloud import pubsub_v1
 from google.cloud import resource_manager
@@ -25,10 +25,10 @@
 import quickstart_updatefeed
 
 PROJECT = os.environ['GCLOUD_PROJECT']
-ASSET_NAME = 'assets-{}'.format(int(time.time()))
-FEED_ID = 'feed-{}'.format(int(time.time()))
-TOPIC = 'topic-{}'.format(int(time.time()))
-NEW_TOPIC = 'new-topic-{}'.format(int(time.time()))
+ASSET_NAME = 'assets-{}'.format(uuid.uuid4().hex)
+FEED_ID = 'feed-{}'.format(uuid.uuid4().hex)
+TOPIC = 'topic-{}'.format(uuid.uuid4().hex)
+NEW_TOPIC = 'new-topic-{}'.format(uuid.uuid4().hex)
 
 
 def test_update_feed(capsys):

asset/snippets/snippets/requirements-test.txt

@@ -1 +1,2 @@
-pytest==5.3.2
+backoff==1.10.0
+pytest==5.4.1

asset/snippets/snippets/requirements.txt

@@ -1,4 +1,4 @@
-google-cloud-storage==1.28.0
+google-cloud-storage==1.28.1
 google-cloud-asset==0.10.0
 google-cloud-resource-manager==0.30.1
 google-cloud-pubsub==1.4.3