import os
os.environ['ROOK_URL'] = 'http://rook.dkrz.de/wps'
from rooki import operators as ops
sub = ops.Subset(
ops.Input(
'cmip6', ['c3s-cmip6.CMIP.SNU.SAM0-UNICON.historical.r1i1p1f1.day.pr.gn.v20190323']
),
time="1860-01-01/1860-12-31",
original_files="1"
)
wf = ops.Average(sub, dims="time")
resp = wf.orchestrate()
assert resp.ok
resp.download_urls()
assert 'pr_day_SAM0-UNICON_historical_r1i1p1f1_gn_avg-t.nc' in resp.download_urls()[0]
assert resp.num_files == 1, resp.num_files
# TODO: file size needs fix ... new catalog
assert int(resp.size) == 258894, resp.size
Provenance:
resp.provenance()