summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorBaudouin Raoult <baudouin.raoult@ecmwf.int>2020-11-19 12:29:40 +0000
committerBaudouin Raoult <baudouin.raoult@ecmwf.int>2020-11-19 12:29:40 +0000
commit3c28f4038e5de54adb45d9213c91ed34978158be (patch)
tree752a0a6da94c0b2c1733bda4b37fa72d21fdaace /examples
parent99437650423ca31552e7e647532b96e7bd340189 (diff)
Check
Diffstat (limited to 'examples')
-rwxr-xr-xexamples/example-era5-update.py34
1 files changed, 19 insertions, 15 deletions
diff --git a/examples/example-era5-update.py b/examples/example-era5-update.py
index 5749e84..8b56573 100755
--- a/examples/example-era5-update.py
+++ b/examples/example-era5-update.py
@@ -16,11 +16,11 @@ c = cdsapi.Client(debug=True, wait_until_complete=False)
r = c.retrieve(
"reanalysis-era5-single-levels",
{
- "variable": "2t",
- "product_type": "reanalysis",
- "date": "2015-12-01",
- "time": "14:00",
- "format": "netcdf",
+ "variable": "2t",
+ "product_type": "reanalysis",
+ "date": "2015-12-01",
+ "time": "14:00",
+ "format": "netcdf",
},
)
@@ -28,20 +28,24 @@ sleep = 30
while True:
r.update()
reply = r.reply
- r.info("Request ID: %s, state: %s" % (reply['request_id'], reply['state']))
+ r.info("Request ID: %s, state: %s" % (reply["request_id"], reply["state"]))
- if reply['state'] == 'completed':
+ if reply["state"] == "completed":
break
- elif reply['state'] in ('queued', 'running'):
- r.info("Request ID: %s, sleep: %s", reply['request_id'], sleep)
+ elif reply["state"] in ("queued", "running"):
+ r.info("Request ID: %s, sleep: %s", reply["request_id"], sleep)
time.sleep(sleep)
- elif reply['state'] in ('failed',):
- r.error("Message: %s", reply['error'].get('message'))
- r.error("Reason: %s", reply['error'].get('reason'))
- for n in reply.get('error', {}).get('context', {}).get('traceback', '').split('\n'):
- if n.strip() == '':
+ elif reply["state"] in ("failed",):
+ r.error("Message: %s", reply["error"].get("message"))
+ r.error("Reason: %s", reply["error"].get("reason"))
+ for n in (
+ reply.get("error", {}).get("context", {}).get("traceback", "").split("\n")
+ ):
+ if n.strip() == "":
break
r.error(" %s", n)
- raise Exception("%s. %s." % (reply['error'].get('message'), reply['error'].get('reason')))
+ raise Exception(
+ "%s. %s." % (reply["error"].get("message"), reply["error"].get("reason"))
+ )
r.download("test.nc")