Skip to content
Snippets Groups Projects
Commit a82d8732 authored by ranchodeluxe's avatar ranchodeluxe
Browse files

delay the results proper to call .compute

parent 166f142f
No related branches found
No related tags found
2 merge requests!106Parallelize Uploads to S3 Where Necessary,!61Additions: primary keys, speed ups (preprocessing and postprocessing), tests, scalene, reorg entire fireatlas
......@@ -139,7 +139,8 @@ def Run(region: Region, tst: TimeStep, ted: TimeStep):
]
# take the DAG and run it
fgb_upload_results[0].compute()
dag = delayed(lambda x: x)(fgb_upload_results)
dag.compute()
dask_client.close()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment