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

stuff

parent 3abc1757
No related branches found
No related tags found
1 merge request!61Additions: primary keys, speed ups (preprocessing and postprocessing), tests, scalene, reorg entire fireatlas
......@@ -24,11 +24,12 @@ def Run(region: fireatlas.FireTypes.Region, tst: fireatlas.FireTypes.TimeStep, t
"""
"""
fire_forward_results = FireRunDaskCoordinator.job_fire_forward([None, ], region, tst, ted)
fire_forward_results.compute()
# 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]))
fgb_upload_results = [
FireRunDaskCoordinator.concurrent_copy_outputs_from_local_to_s3(fire_forward_results, local_filepath)
FireRunDaskCoordinator.concurrent_copy_outputs_from_local_to_s3([None,], local_filepath)
for local_filepath in list(chain(
glob.glob(os.path.join(data_dir, "Snapshot", "*", "*.fgb")),
glob.glob(os.path.join(data_dir, "Largefire", "*", "*.fgb"))
......
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