| From fdad94561b8acd25fc0d265642686fb2d9e0923d Mon Sep 17 00:00:00 2001 |
| From: Ke Wu <mikewu@google.com> |
| Date: Fri, 12 Jan 2018 16:35:02 -0800 |
| Subject: [PATCH] Add retries to DataSourceGCE.py when connecting to GCE |
| metadata server |
| |
| Signed-off-by: Wei Xu <weixugc@google.com> |
| --- |
| cloudinit/sources/DataSourceGCE.py | 7 ++++++- |
| 1 file changed, 6 insertions(+), 1 deletion(-) |
| |
| diff --git a/cloudinit/sources/DataSourceGCE.py b/cloudinit/sources/DataSourceGCE.py |
| index 6cbfbbac..7fb43c09 100644 |
| --- a/cloudinit/sources/DataSourceGCE.py |
| +++ b/cloudinit/sources/DataSourceGCE.py |
| @@ -28,6 +28,8 @@ class GoogleMetadataFetcher(object): |
| |
| def __init__(self, metadata_address): |
| self.metadata_address = metadata_address |
| + self.retries = 5 |
| + self.retries_sec_between = 1 |
| |
| def get_value(self, path, is_text, is_recursive=False): |
| value = None |
| @@ -35,7 +37,10 @@ class GoogleMetadataFetcher(object): |
| url = self.metadata_address + path |
| if is_recursive: |
| url += '/?recursive=True' |
| - resp = url_helper.readurl(url=url, headers=HEADERS) |
| + resp = url_helper.readurl(url=url, |
| + headers=HEADERS, |
| + retries=self.retries, |
| + sec_between=self.retries_sec_between) |
| except url_helper.UrlError as exc: |
| msg = "url %s raised exception %s" |
| LOG.debug(msg, path, exc) |
| -- |
| 2.25.1.481.gfbce0eb801-goog |
| |
