testing: various cleanups (#3877)

* testing: various cleanups

* [iap]: only run iap tests on Kokoro
* [vision/automl]: use temporary directory for temporary files
* [appengine/flexible/scipy]: use temporary directory
* [bigtable/snippets/reads]: update pytest snapshot
* [texttospeech/cloud-client]: added output.mp3 to .gitignore
* [iot/api-client/gcs_file_to_device]: use temporary directory
* [iot/api-client/mqtt_example]: use temporary directory
* [logging/cloud-client]: use uuid and add backoff

* use project directory with Trampoline V1

Author: Takashi Matsuo

appengine/flexible/scipy/assets/resized_google_logo.jpg

@@ -16,6 +16,7 @@
 import os
 
 from flask import Flask
+from flask import request
 import imageio
 from PIL import Image
 
@@ -30,8 +31,7 @@ def resize():
     img = Image.fromarray(imageio.imread(image_path))
     img_tinted = img.resize((300, 300))
 
-    output_image_path = os.path.join(
-        app_path, 'assets/resized_google_logo.jpg')
+    output_image_path = request.args.get('output_image_path')
     # Write the tinted image back to disk
     imageio.imwrite(output_image_path, img_tinted)
     return "Image resized."

appengine/flexible/scipy/fixtures/assets/resized_google_logo.jpg

@@ -13,23 +13,18 @@
 # limitations under the License.
 
 import os
+import tempfile
 
 import main
 
 
 def test_index():
     main.app.testing = True
     client = main.app.test_client()
-    test_path = os.path.dirname(os.path.realpath(__file__))
-    asset_path = os.path.join(
-        test_path, 'assets/resized_google_logo.jpg')
-    fixtured_path = os.path.join(
-        test_path, 'fixtures/assets/resized_google_logo.jpg')
-    try:
-        os.remove(asset_path)
-    except OSError:
-        pass  # if doesn't exist
-    r = client.get('/')
+    with tempfile.TemporaryDirectory() as test_dir:
+        output_image_path = os.path.join(test_dir, 'resized_google_logo.jpg')
+        r = client.get(
+            '/', query_string={'output_image_path': output_image_path})
 
-    assert os.path.isfile(fixtured_path)
-    assert r.status_code == 200
+        assert os.path.isfile(output_image_path)
+        assert r.status_code == 200

appengine/flexible/scipy/main.py

@@ -7,14 +7,6 @@
 
 snapshots = Snapshot()
 
-snapshots['test_read_simple 1'] = '''Reading data for phone#4c410523#20190501:
-Column Family stats_summary
-\tconnected_cell: \x00\x00\x00\x00\x00\x00\x00\x01 @2019-05-01 00:00:00+00:00
-\tconnected_wifi: \x00\x00\x00\x00\x00\x00\x00\x01 @2019-05-01 00:00:00+00:00
-\tos_build: PQ2A.190405.003 @2019-05-01 00:00:00+00:00
-
-'''
-
 snapshots['test_read_row_partial 1'] = '''Reading data for phone#4c410523#20190501:
 Column Family stats_summary
 \tos_build: PQ2A.190405.003 @2019-05-01 00:00:00+00:00
@@ -140,3 +132,11 @@
 \tos_build: PQ2A.190406.000 @2019-05-01 00:00:00+00:00
 
 '''
+
+snapshots['test_read_row 1'] = '''Reading data for phone#4c410523#20190501:
+Column Family stats_summary
+\tconnected_cell: \x00\x00\x00\x00\x00\x00\x00\x01 @2019-05-01 00:00:00+00:00
+\tconnected_wifi: \x00\x00\x00\x00\x00\x00\x00\x01 @2019-05-01 00:00:00+00:00
+\tos_build: PQ2A.190405.003 @2019-05-01 00:00:00+00:00
+
+'''

appengine/flexible/scipy/main_test.py

@@ -14,6 +14,8 @@
 
 """Test script for Identity-Aware Proxy code samples."""
 
+import os
+
 import pytest
 
 import make_iap_request
@@ -36,6 +38,10 @@
 
 @pytest.mark.flaky
 def test_main(capsys):
+    # It only passes on Kokoro now. Skipping in other places.
+    # The envvar `TRAMPOLINE_CI` will be set once #3860 is merged.
+    if os.environ.get('TRAMPOLINE_CI', 'kokoro') != 'kokoro':
+        pytest.skip('Only passing on Kokoro.')
     # JWTs are obtained by IAP-protected applications whenever an
     # end-user makes a request.  We've set up an app that echoes back
     # the JWT in order to expose it to this test.  Thus, this test

bigtable/snippets/reads/snapshots/snap_reads_test.py

@@ -13,6 +13,7 @@
 # limitations under the License.
 
 import os
+import tempfile
 
 from google.cloud import storage
 
@@ -22,7 +23,6 @@
 
 gcs_bucket = os.environ['CLOUD_STORAGE_BUCKET']
 cloud_region = 'us-central1'
-destination_file_name = 'destination-file.bin'
 project_id = os.environ['GCLOUD_PROJECT']
 
 
@@ -41,8 +41,10 @@ def test_blob():
 
 
 def test_download_blob(test_blob, capsys):
-    device.download_blob(gcs_bucket, test_blob.name, destination_file_name)
+    with tempfile.TemporaryDirectory() as tmp_dir:
+        destination_file_name = os.path.join(tmp_dir, 'destination-file.bin')
+        device.download_blob(gcs_bucket, test_blob.name, destination_file_name)
 
-    out, _ = capsys.readouterr()
-    assert 'Config {} downloaded to {}.'.format(
-        test_blob.name, destination_file_name) in out
+        out, _ = capsys.readouterr()
+        assert 'Config {} downloaded to {}.'.format(
+            test_blob.name, destination_file_name) in out

iap/iap_test.py

@@ -14,6 +14,7 @@
 # limitations under the License.
 import os
 import sys
+import tempfile
 
 # Add manager as library
 sys.path.append(os.path.join(os.path.dirname(__file__), '..', 'manager'))  # noqa
@@ -63,8 +64,9 @@ def test_image_recv(
         cloud_region, test_registry_id, test_device_id, rsa_private_path,
         ca_cert_path, image_path, project_id, service_account_json)
 
-    cloudiot_mqtt_image.receive_image(
-        project_id, test_subscription.name, 'test', 'png', 120)
+    with tempfile.TemporaryDirectory() as tmp_dir:
+        cloudiot_mqtt_image.receive_image(
+            project_id, test_subscription.name, tmp_dir + '/test', 'png', 120)
 
     out, _ = capsys.readouterr()
     assert 'Received image' in out

iot/api-client/gcs_file_to_device/gcs_example_mqtt_device_test.py

@@ -12,14 +12,17 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import uuid
+
 import backoff
+from google.api_core.exceptions import NotFound
 from google.cloud import logging
 import pytest
 
 import snippets
 
 
-TEST_LOGGER_NAME = 'example_log'
+TEST_LOGGER_NAME = 'example_log_{}'.format(uuid.uuid4().hex)
 
 
 @pytest.fixture
@@ -46,6 +49,8 @@ def test_write():
 
 
 def test_delete(example_log, capsys):
-    snippets.delete_logger(TEST_LOGGER_NAME)
-    out, _ = capsys.readouterr()
-    assert TEST_LOGGER_NAME in out
+    @backoff.on_exception(backoff.expo, NotFound, max_time=120)
+    def eventually_consistent_test():
+        snippets.delete_logger(TEST_LOGGER_NAME)
+        out, _ = capsys.readouterr()
+        assert TEST_LOGGER_NAME in out

iot/api-client/mqtt_example/cloudiot_mqtt_image_test.py

@@ -0,0 +1 @@
+output.mp3