diff options
author | Jesper Baasch-Larsen <jbl@greensteam.com> | 2019-05-07 07:17:34 +0200 |
---|---|---|
committer | Jesper Baasch-Larsen <jbl@greensteam.com> | 2019-05-07 07:17:34 +0200 |
commit | 72a09646f39130fd3e1530139a4b71dfd8d89b8e (patch) | |
tree | f20daac193d5efb46a973da8dcab18f2c4efa25f /cdsapi/api.py | |
parent | 9af2dabc01e47552c19c581df66cd6698715b99a (diff) |
FEATURE_SEPARATE_RETRIEVE_DOWNLOAD: added support for updating request outside while loop
Diffstat (limited to 'cdsapi/api.py')
-rw-r--r-- | cdsapi/api.py | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/cdsapi/api.py b/cdsapi/api.py index 88a3a8c..fb0b59d 100644 --- a/cdsapi/api.py +++ b/cdsapi/api.py @@ -116,6 +116,14 @@ class Result(object): self.debug(metadata.headers) return metadata + def update(self): + task_url = '%s/tasks/%s' % (self._url, self.reply['request_id']) + self.debug("GET %s", task_url) + + result = self.robust(self.session.get)(task_url, verify=self.verify) + result.raise_for_status() + self.reply = result.json() + def delete(self): if self._deleted: @@ -161,6 +169,7 @@ class Client(object): delete=True, retry_max=500, sleep_max=120, + wait_until_complete=True, info_callback=None, warning_callback=None, error_callback=None, @@ -206,6 +215,7 @@ class Client(object): self.full_stack = full_stack self.delete = delete self.last_state = None + self.wait_until_complete = wait_until_complete self.debug_callback = debug_callback self.warning_callback = warning_callback @@ -271,6 +281,9 @@ class Client(object): else: raise + if not self.wait_until_complete: + return Result(self, reply) + sleep = 1 start = time.time() |