Repository: beam Updated Branches: refs/heads/master 8503adbbc -> 0aae7aa5f
Fixes a pydocs validation failure due to a recent commit. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8dc6e166 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8dc6e166 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8dc6e166 Branch: refs/heads/master Commit: 8dc6e1666f3f113fe5ee854f4c7060e0fbd614e1 Parents: 8503adb Author: [email protected] <[email protected]> Authored: Thu Aug 17 18:21:44 2017 -0700 Committer: [email protected] <[email protected]> Committed: Thu Aug 17 18:21:44 2017 -0700 ---------------------------------------------------------------------- .../io/gcp/datastore/v1/adaptive_throttler.py | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/8dc6e166/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py b/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py index 4dfd675..7d94f24 100644 --- a/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py +++ b/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py @@ -41,12 +41,16 @@ class AdaptiveThrottler(object): MIN_REQUESTS = 1 def __init__(self, window_ms, bucket_ms, overload_ratio): - """Args: - window_ms: int, length of history to consider, in ms, to set throttling. - bucket_ms: int, granularity of time buckets that we store data in, in ms. - overload_ratio: float, the target ratio between requests sent and - successful requests. This is "K" in the formula in - https://landing.google.com/sre/book/chapters/handling-overload.html + """Initializes AdaptiveThrottler. + + Args: + window_ms: int, length of history to consider, in ms, to set + throttling. + bucket_ms: int, granularity of time buckets that we store data in, in + ms. + overload_ratio: float, the target ratio between requests sent and + successful requests. This is "K" in the formula in + https://landing.google.com/sre/book/chapters/handling-overload.html. """ self._all_requests = util.MovingSum(window_ms, bucket_ms) self._successful_requests = util.MovingSum(window_ms, bucket_ms)
