Consumer¶
This is a downstream Application Package that produces the mean value using as input the Zarr store of the detected water bodies described as a STAC Collection including the STAC Datacube extension
In [1]:
Copied!
import os
import sys
module_path = os.path.abspath(os.path.join(".."))
sys.path.insert(0, module_path)
from helpers import WorkflowViewer
import cwl_loader
cwl_loader.logger.remove()
cwl_loader.logger.add(sys.stderr, level="INFO")
import os
import sys
module_path = os.path.abspath(os.path.join(".."))
sys.path.insert(0, module_path)
from helpers import WorkflowViewer
import cwl_loader
cwl_loader.logger.remove()
cwl_loader.logger.add(sys.stderr, level="INFO")
Out[1]:
1
Plot the Application Paca
In [2]:
Copied!
version = "0.3.0"
wf = WorkflowViewer.from_file(f"https://github.com/eoap/zarr-cloud-native-format/releases/download/{version}/app-water-bodies-occurrence.{version}.cwl", "water-bodies-occurrence")
version = "0.3.0"
wf = WorkflowViewer.from_file(f"https://github.com/eoap/zarr-cloud-native-format/releases/download/{version}/app-water-bodies-occurrence.{version}.cwl", "water-bodies-occurrence")
In [3]:
Copied!
wf.plot()
wf.plot()
Out[3]:
Inputs¶
In [4]:
Copied!
wf.display_inputs()
wf.display_inputs()
| Id | Type | Label | Doc |
|---|---|---|---|
zarr-stac-catalog |
Directory |
Zarr store STAC Catalog | Input STAC catalog with datacube |
Steps¶
In [5]:
Copied!
wf.display_steps()
wf.display_steps()
| Id | Runs | Label | Doc |
|---|---|---|---|
step_occurrence |
#occurrence |
Water bodies occurrence | Water bodies occurrence based on NDWI and otsu threshold |
Outputs¶
In [6]:
Copied!
wf.display_outputs()
wf.display_outputs()
| Id | Type | Label | Doc |
|---|---|---|---|
stac-catalog |
Directory |
STAC catalog | Output STAC catalog with water bodies occurrence |
Component diagram¶
In [7]:
Copied!
wf.display_components_diagram()
wf.display_components_diagram()
Class diagram¶
In [8]:
Copied!
wf.display_class_diagram()
wf.display_class_diagram()
In [ ]:
Copied!