run_kaska.py

#!/usr/bin/env python

import datetime as dt

from dask.distributed import Client

from kaska import utils
from kaska.entry import run_process


if __name__ == "__main__":

    # Enable dask parallel execution
    client = Client(scheduler_file='/home/ucfajlg/scheduler.json')
    # disable dask
    client= None

    start_date = dt.datetime(2017, 3, 1)
    end_date = dt.datetime(2017,11, 1)
    temporal_grid_space = 5
    s2_folder = "/home/ucfajlg/Data/python/KaFKA_Validation/LMU/s2_obs/"
    state_mask = "/home/ucfajlg/Data/python/KaFKA_Validation/LMU/carto/ESU.tif"
    s1_ncfile = "/data/selene/ucfajlg/ELBARA_LMU/" + \
                "mirror_ftp/141.84.52.201/S1/S1_LMU_site_2017_new.nc "
    output_folder = f"{s2_folder:s}/outputs"

    run_process(start_date, end_date, temporal_grid_space, s2_folder,
                s1_ncfile, state_mask, prior_dist, output_folder, debug=True,
                logfile=None, dask_client=None, block_size=[256, 256])