Index: tools/telemetry/third_party/gsutil/gslib/tests/test_versioning.py |
diff --git a/tools/telemetry/third_party/gsutil/gslib/tests/test_versioning.py b/tools/telemetry/third_party/gsutil/gslib/tests/test_versioning.py |
deleted file mode 100644 |
index 37d21cf70de21b299fbebba5bab01f6a34bf8bb0..0000000000000000000000000000000000000000 |
--- a/tools/telemetry/third_party/gsutil/gslib/tests/test_versioning.py |
+++ /dev/null |
@@ -1,90 +0,0 @@ |
-# -*- coding: utf-8 -*- |
-# Copyright 2013 Google Inc. All Rights Reserved. |
-# |
-# Licensed under the Apache License, Version 2.0 (the "License"); |
-# you may not use this file except in compliance with the License. |
-# You may obtain a copy of the License at |
-# |
-# http://www.apache.org/licenses/LICENSE-2.0 |
-# |
-# Unless required by applicable law or agreed to in writing, software |
-# distributed under the License is distributed on an "AS IS" BASIS, |
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
-# See the License for the specific language governing permissions and |
-# limitations under the License. |
-"""Integration tests for versioning command.""" |
- |
-from __future__ import absolute_import |
- |
-import gslib.tests.testcase as testcase |
-from gslib.tests.util import ObjectToURI as suri |
-from gslib.util import Retry |
- |
- |
-class TestVersioning(testcase.GsUtilIntegrationTestCase): |
- """Integration tests for versioning command.""" |
- |
- _set_ver_cmd = ['versioning', 'set'] |
- _get_ver_cmd = ['versioning', 'get'] |
- |
- def test_off_default(self): |
- bucket_uri = self.CreateBucket() |
- stdout = self.RunGsUtil( |
- self._get_ver_cmd + [suri(bucket_uri)], return_stdout=True) |
- self.assertEqual(stdout.strip(), '%s: Suspended' % suri(bucket_uri)) |
- |
- def test_turning_on(self): |
- bucket_uri = self.CreateBucket() |
- self.RunGsUtil(self._set_ver_cmd + ['on', suri(bucket_uri)]) |
- |
- # Work around eventual consistency for S3 versioning. |
- @Retry(AssertionError, tries=3, timeout_secs=1) |
- def _Check1(): |
- stdout = self.RunGsUtil( |
- self._get_ver_cmd + [suri(bucket_uri)], return_stdout=True) |
- self.assertEqual(stdout.strip(), '%s: Enabled' % suri(bucket_uri)) |
- _Check1() |
- |
- def test_turning_off(self): |
- bucket_uri = self.CreateBucket() |
- self.RunGsUtil(self._set_ver_cmd + ['on', suri(bucket_uri)]) |
- |
- # Work around eventual consistency for S3 versioning. |
- @Retry(AssertionError, tries=3, timeout_secs=1) |
- def _Check1(): |
- stdout = self.RunGsUtil( |
- self._get_ver_cmd + [suri(bucket_uri)], return_stdout=True) |
- self.assertEqual(stdout.strip(), '%s: Enabled' % suri(bucket_uri)) |
- _Check1() |
- |
- self.RunGsUtil(self._set_ver_cmd + ['off', suri(bucket_uri)]) |
- |
- # Work around eventual consistency for S3 versioning. |
- @Retry(AssertionError, tries=3, timeout_secs=1) |
- def _Check2(): |
- stdout = self.RunGsUtil( |
- self._get_ver_cmd + [suri(bucket_uri)], return_stdout=True) |
- self.assertEqual(stdout.strip(), '%s: Suspended' % suri(bucket_uri)) |
- _Check2() |
- |
- def testTooFewArgumentsFails(self): |
- """Ensures versioning commands fail with too few arguments.""" |
- # No arguments for set, but valid subcommand. |
- stderr = self.RunGsUtil(self._set_ver_cmd, return_stderr=True, |
- expected_status=1) |
- self.assertIn('command requires at least', stderr) |
- |
- # No arguments for get, but valid subcommand. |
- stderr = self.RunGsUtil(self._get_ver_cmd, return_stderr=True, |
- expected_status=1) |
- self.assertIn('command requires at least', stderr) |
- |
- # Neither arguments nor subcommand. |
- stderr = self.RunGsUtil(['versioning'], return_stderr=True, |
- expected_status=1) |
- self.assertIn('command requires at least', stderr) |
- |
- |
-class TestVersioningOldAlias(TestVersioning): |
- _set_ver_cmd = ['setversioning'] |
- _get_ver_cmd = ['getversioning'] |