Repository: beam Updated Branches: refs/heads/master 7564486f5 -> d18db9344
Reduce test times for two retry based tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ade9c33d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ade9c33d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ade9c33d Branch: refs/heads/master Commit: ade9c33d49997515cac8edf16cb9a5122c3a71b5 Parents: 7564486 Author: Sourabh Bajaj <[email protected]> Authored: Sun Feb 5 20:18:52 2017 -0800 Committer: Ahmet Altay <[email protected]> Committed: Mon Feb 6 10:17:52 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/io/gcsio_test.py | 2 +- sdks/python/apache_beam/utils/retry_test.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/ade9c33d/sdks/python/apache_beam/io/gcsio_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/io/gcsio_test.py b/sdks/python/apache_beam/io/gcsio_test.py index 6532707..06371aa 100644 --- a/sdks/python/apache_beam/io/gcsio_test.py +++ b/sdks/python/apache_beam/io/gcsio_test.py @@ -435,7 +435,7 @@ class TestGCSIO(unittest.TestCase): f = self.gcs.open(file_name) random.seed(0) f.buffer_size = 1024 * 1024 - f.segment_timeout = 0.1 + f.segment_timeout = 0.01 self.assertEqual(f.mode, 'r') f._real_get_segment = f._get_segment http://git-wip-us.apache.org/repos/asf/beam/blob/ade9c33d/sdks/python/apache_beam/utils/retry_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/utils/retry_test.py b/sdks/python/apache_beam/utils/retry_test.py index 7570ca0..46f6e54 100644 --- a/sdks/python/apache_beam/utils/retry_test.py +++ b/sdks/python/apache_beam/utils/retry_test.py @@ -51,7 +51,7 @@ def test_function(a, b): raise NotImplementedError [email protected]_exponential_backoff(initial_delay_secs=1.0, num_retries=1) [email protected]_exponential_backoff(initial_delay_secs=0.1, num_retries=1) def test_function_with_real_clock(a, b): _ = a, b raise NotImplementedError
