Application integration

Now that the node template has an associated job template, it is now time put it in a workflow.

The workflow is a Directed Acyclic Graphs (DAG) where nodes and their relation(s), the source(s) are defined.

This application’s workflow is the simplest case: a workflow with a single node:

!define DIAG_NAME Workflow example

!include includes/skins.iuml

skinparam backgroundColor #FFFFFF
skinparam componentStyle uml2

start

:node_flh;

stop

Each node of DAG has:

  • a unique node identifier
  • a job template id reference
  • one or more sources
  • one or more parameters and associated values to overide the default values (if defined in the job template).

The node_flh node

The first node of the DAG with the unique identifer set to node_flh instantiates the flh-proc job template.

    </jobTemplate>
  </jobTemplates>
  <workflow id="flh-wf" title="FLH Workflow" abstract="This is a process workflow that computes MERIS Level 1 product with the Fluorescence Line Height Operator for BEAM toolbox (based on BEAM tutorial)">
    <workflowVersion>1.0</workflowVersion>
    <node id="node_flh">
      <job id="flh-proc"/>
      <sources>
        <source refid="cas:series">https://data2.terradue.com/eop/eo-samples/series/mer_rr__1p/description</source>
      </sources>
      <parameters>
        <parameter type="opensearch" target="time:start" id="startdate">2012-04-04T00:00:00</parameter>
        <parameter type="opensearch" target="time:end" id="enddate">2012-04-04:23:59:59</parameter>
      </parameters>
    </node>

As source, this node uses the sandbox catalogue:

      <job id="flh-proc"/>
      <sources>
        <source refid="cas:series">https://data2.terradue.com/eop/eo-samples/series/mer_rr__1p/description</source>

As parameters, it defines the values for the start and enddate and leaves the expression default value.

      </sources>
      <parameters>
        <parameter type="opensearch" target="time:start" id="startdate">2012-04-04T00:00:00</parameter>
        <parameter type="opensearch" target="time:end" id="enddate">2012-04-04:23:59:59</parameter>

The complete node node_flh definition is:

    <workflowVersion>1.0</workflowVersion>
    <node id="node_flh">
      <job id="flh-proc"/>
      <sources>
        <source refid="cas:series">https://data2.terradue.com/eop/eo-samples/series/mer_rr__1p/description</source>
      </sources>
      <parameters>
        <parameter type="opensearch" target="time:start" id="startdate">2012-04-04T00:00:00</parameter>
        <parameter type="opensearch" target="time:end" id="enddate">2012-04-04:23:59:59</parameter>
      </parameters>

Workflow

The complete workflow is:

    </jobTemplate>
  </jobTemplates>
  <workflow id="flh-wf" title="FLH Workflow" abstract="This is a process workflow that computes MERIS Level 1 product with the Fluorescence Line Height Operator for BEAM toolbox (based on BEAM tutorial)">
    <workflowVersion>1.0</workflowVersion>
    <node id="node_flh">
      <job id="flh-proc"/>
      <sources>
        <source refid="cas:series">https://data2.terradue.com/eop/eo-samples/series/mer_rr__1p/description</source>
      </sources>
      <parameters>
        <parameter type="opensearch" target="time:start" id="startdate">2012-04-04T00:00:00</parameter>
        <parameter type="opensearch" target="time:end" id="enddate">2012-04-04:23:59:59</parameter>
      </parameters>
    </node>