...
Boolean flag to indicate if the activity it to be run as many times are there are members in the ensemble, or if it is to be run only once, but will use all members of the ensemble in that single run. If the value is set to "true", then when running the workflow DELFT-FEWS will first establish how many members there are in the ensemble, and then run the activity for each member. If the value is set to "false" then the activity will be run only once. On requesting a time series set within the modules to be run, the database will return all members of that ensemble.
ensembleMemberIndex
Optional field to only run one particular ensemble member. If this field is used only the specified ensemble member will be run.
ensembleMemberIndexRange
Optional field to run a particular range of ensemble members. Processing starts at member start and ends at member end. If end is not specified the processing will start at start and end at the last member of the ensemble.
| Info |
|---|
Activities in a workflow or nested workflows may be called only once. This is to avoid mistakes through multiple calls to the same activity in different locations thus creating ambiguous results, or circular references in defining fallback activities. |
| Info |
|---|
When running activities as an ensemble that request time series sets from the database that are not a part of that ensemble, the default ensembleId should be added to the TimeSeriesSets definition. The default ensemble Id is "main". All time series sets written when running in ensemble mode will have the ensembleId as specified in the workflow ensembleId element, unless overruled by a local ensembleId defined in the timeSeriesSet on writing. |
...
Examples
The workflow below runs seven moduleInstances. If the first moduleInstance fails in this example all other processing is stopped. If any of the other activities fail the processing will continue.
| No Format |
|---|
<?xml version="1.0" encoding="UTF-8"?>
<workflow version="1.1" xmlns="http://www.wldelft.nl/fews" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.wldelft.nl/fews
E:\schemas\workflow.xsd">
<activity>
<runIndependent>false</runIndependent>
<moduleInstanceId>Astronomical</moduleInstanceId>
</activity>
<activity>
<runIndependent>true</runIndependent>
<moduleInstanceId>BackupPrecipitation_Forecast</moduleInstanceId>
</activity>
<runIndependent>true</runIndependent>
<moduleInstanceId>PrecipitationGaugeToGrid_Forecast</moduleInstanceId>
</activity>
<activity>
<runIndependent>true</runIndependent>
<moduleInstanceId>Spatial_Interpolation_Precipitation_Forecast</moduleInstanceId>
</activity>
<activity>
<runIndependent>true</runIndependent>
<moduleInstanceId>MergePrecipitation_Forecast</moduleInstanceId>
</activity>
<activity>
<runIndependent>true</runIndependent>
<moduleInstanceId>GridToCatchments_Forecast</moduleInstanceId>
</activity>
<activity>
<runIndependent>true</runIndependent>
<moduleInstanceId>Singapore_Sobek_Forecast</moduleInstanceId>
</activity>
</workflow>
|
The example below is more complex and includes several modules that are run in ensemble mode.
| No Format |
|---|
<?xml version="1.0" encoding="UTF-8"?> <workflow xmlns="http://www.wldelft.nl/fews" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.wldelft.nl/fews http://fews.wldelft.nl/schemas/version1.0/workflow.xsd" version="1.1"> <!--Run Rhein Interpolation --> <activity> <runIndependent>true</runIndependent> <workflowId>Rhein_Interpolate</workflowId> </activity> <!--Spatial interpolation from grid to HBV-centroids--> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>Rhein_SpatialInterpolationCOSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Aggregate forecast data for display --> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>Rhein_AggregateForecast_COSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Disaggregate timeseries at HBV-centroids --> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>Rhein_DisaggregateSeriesCOSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Merge timeseries from historical run and forecast run --> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>HBV_Rhein_Merge_COSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Aggregate inputs for display --> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>HBV_Rhein_AggregateInputs_COSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Interpolate timeseries from historical run and forecast run --> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>HBV_Rhein_Interpolate_COSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Run HBV-model for forecast period--> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>HBV_Rhein_COSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Run ErrorModule for forecast period--> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>HBV_Rhein_AR_COSMO-LEPS</moduleInstanceId> <ensemble> <ensembleId>COSMO-LEPS</ensembleId> <runInLoop>true</runInLoop> </ensemble> </activity> <!--Calculate Statistics--> <activity> <runIndependent>true</runIndependent> <workflowId>Statistics_COSMO-LEPS</workflowId> </activity> <!--Export forecast data to wavos format --> <activity> <runIndependent>true</runIndependent> <moduleInstanceId>Rhein_ExportForecast_COSMO-LEPS</moduleInstanceId> </activity> </workflow> |