Simplified efast run.
This commit is contained in:
parent
585919d130
commit
915dfd8510
2 changed files with 4 additions and 12 deletions
13
fusion.py
13
fusion.py
|
|
@ -1,14 +1,7 @@
|
||||||
"""EFAST fusion: S2/S3 reflectance fusion for four scenarios."""
|
"""EFAST fusion: S2/S3 reflectance fusion for four scenarios."""
|
||||||
from pathlib import Path
|
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
|
|
||||||
from preselection import create_timeseries
|
from preparation import _get_base_dir, RESOLUTION_RATIO
|
||||||
from preparation import (
|
|
||||||
prepare_s2,
|
|
||||||
prepare_s3,
|
|
||||||
_get_base_dir,
|
|
||||||
RESOLUTION_RATIO,
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
def _import_efast():
|
def _import_efast():
|
||||||
|
|
@ -68,9 +61,7 @@ def run_efast(season, site_position, site_name, cleaning_strategy="aggressive",
|
||||||
|
|
||||||
|
|
||||||
def run_all_efast_scenarios(season, site_position, site_name, sigma_value=30, date_range=None):
|
def run_all_efast_scenarios(season, site_position, site_name, sigma_value=30, date_range=None):
|
||||||
create_timeseries(season, site_position, site_name)
|
"""Run EFAST fusion for all 4 scenarios. Expects prepared_*/s2 and prepared_*/s3 to exist."""
|
||||||
for strategy in ["aggressive", "nonaggressive"]:
|
for strategy in ["aggressive", "nonaggressive"]:
|
||||||
prepare_s2(season, site_position, site_name, cleaning_strategy=strategy, date_range=date_range)
|
|
||||||
prepare_s3(season, site_position, site_name, cleaning_strategy=strategy, date_range=date_range)
|
|
||||||
run_efast(season, site_position, site_name, cleaning_strategy=strategy, sigma=None, date_range=date_range)
|
run_efast(season, site_position, site_name, cleaning_strategy=strategy, sigma=None, date_range=date_range)
|
||||||
run_efast(season, site_position, site_name, cleaning_strategy=strategy, sigma=sigma_value, date_range=date_range)
|
run_efast(season, site_position, site_name, cleaning_strategy=strategy, sigma=sigma_value, date_range=date_range)
|
||||||
|
|
|
||||||
3
run.py
3
run.py
|
|
@ -1,4 +1,4 @@
|
||||||
# from fusion import run_all_efast_scenarios
|
from fusion import run_all_efast_scenarios
|
||||||
# from postprocessing import process_all_scenarios
|
# from postprocessing import process_all_scenarios
|
||||||
# from metrics_indices import (
|
# from metrics_indices import (
|
||||||
# create_ndvi_timeseries_post_process,
|
# create_ndvi_timeseries_post_process,
|
||||||
|
|
@ -31,6 +31,7 @@ def run_pipeline(season, site_position, site_name):
|
||||||
|
|
||||||
print(f"Running EFAST fusion for all scenarios: {site_name}, {season}")
|
print(f"Running EFAST fusion for all scenarios: {site_name}, {season}")
|
||||||
run_all_efast_scenarios(season, site_position, site_name)
|
run_all_efast_scenarios(season, site_position, site_name)
|
||||||
|
|
||||||
# print(f"Post-processing data: {site_name}, {season}")
|
# print(f"Post-processing data: {site_name}, {season}")
|
||||||
# process_all_scenarios(season, site_position, site_name)
|
# process_all_scenarios(season, site_position, site_name)
|
||||||
# print(f"Generating NDVI for final outputs: {site_name}, {season}")
|
# print(f"Generating NDVI for final outputs: {site_name}, {season}")
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue