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

two computes

parent 4f23a9f9
No related branches found
No related tags found
1 merge request!61Additions: primary keys, speed ups (preprocessing and postprocessing), tests, scalene, reorg entire fireatlas
Hide whitespace changes
Inline Side-by-side
fireatlas/FireRunDaskCoordinator.py
+ 2
− 1
View file @ 29a469f0
...@@ -136,11 +136,12 @@ def Run(region: Region, tst: TimeStep, ted: TimeStep): ...@@ -136,11 +136,12 @@ def Run(region: Region, tst: TimeStep, ted: TimeStep):
# blocks on region_and_t_results and then runs fire forward algorithm (which cannot be run in parallel) # blocks on region_and_t_results and then runs fire forward algorithm (which cannot be run in parallel)
fire_forward_results = job_fire_forward(region_and_t_results, region, tst, ted) fire_forward_results = job_fire_forward(region_and_t_results, region, tst, ted)
fire_forward_results.compute()
# take all fire forward output and upload all snapshots/largefire outputs in parallel # take all fire forward output and upload all snapshots/largefire outputs in parallel
data_dir = os.path.join(settings.LOCAL_PATH, settings.OUTPUT_DIR, region[0], str(tst[0])) data_dir = os.path.join(settings.LOCAL_PATH, settings.OUTPUT_DIR, region[0], str(tst[0]))
fgb_upload_results = [ fgb_upload_results = [
concurrent_copy_outputs_from_local_to_s3([fire_forward_results,], local_filepath) concurrent_copy_outputs_from_local_to_s3([None,], local_filepath)
for local_filepath in list(chain( for local_filepath in list(chain(
glob.glob(os.path.join(data_dir, "Snapshot", "*", "*.fgb")), glob.glob(os.path.join(data_dir, "Snapshot", "*", "*.fgb")),
glob.glob(os.path.join(data_dir, "Largefire", "*", "*.fgb")) glob.glob(os.path.join(data_dir, "Largefire", "*", "*.fgb"))
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment