diff options
author | Baudouin Raoult <baudouin.raoult@ecmwf.int> | 2020-11-19 12:29:40 +0000 |
---|---|---|
committer | Baudouin Raoult <baudouin.raoult@ecmwf.int> | 2020-11-19 12:29:40 +0000 |
commit | 3c28f4038e5de54adb45d9213c91ed34978158be (patch) | |
tree | 752a0a6da94c0b2c1733bda4b37fa72d21fdaace /examples | |
parent | 99437650423ca31552e7e647532b96e7bd340189 (diff) |
Check
Diffstat (limited to 'examples')
-rwxr-xr-x | examples/example-era5-update.py | 34 |
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") |