Workflow schema

This is the json schema describing workflows. It is defined in malleefowl/custom_workflow.py

Workflow

Advanced workflow schema
type object
properties
  • tasks
Array of workflow task
type array
items
#/definitions/workflow_task_schema
minItems 1
  • name
Workflow name
type string
  • parallel_groups
Array of group of tasks being executed on multiple processes
type array
items
#/definitions/group_of_task_schema
minItems 1
additionalProperties False
minProperties 2
definitions
  • workflow_task_schema
Describe a WPS process task
type object
properties
  • inputs
Dictionary of inputs that must be fed to the WPS process
type object
patternProperties
  • .*
oneOf
Data that must be fed to this input
type string
Array of data that must be fed to this input
type array
items
type string
minItems 1
  • name
Unique name given to each workflow task
type string
  • url
Url of the WPS provider
type string
  • linked_inputs
Dictionary of dynamic inputs that must be fed to the WPS process and obtained by the output of other tasks
type object
patternProperties
  • .*
oneOf
#/definitions/input_description_schema
Array of input description that must be fed to this input
type array
items
#/definitions/input_description_schema
minItems 1
  • identifier
Identifier of a WPS process
type string
  • progress_range
Progress range to map the whole progress of this task
type array
items
type number
maximum 100
minimum 0
maxItems 2
minItems 2
additionalProperties False
  • input_description_schema
Description of an input source
type object
properties
  • output
Task output name
type string
  • as_reference
Specify if the task output should be obtained as a reference or not
type boolean
  • task
Task name
type string
additionalProperties False
  • group_of_task_schema
Describe a group of tasks to be run concurrently
type object
properties
  • max_processes
Number of processes to run concurrently to process the data
type number
minimum 1
  • tasks
Array of workflow task to run concurrently inside the group
type array
items
#/definitions/workflow_task_schema
minItems 1
  • reduce
#/definitions/input_description_schema
  • name
Group of task name
type string
  • map
oneOf
#/definitions/input_description_schema
Array of data that has to be mapped directly
type array
items
type string
minItems 1
additionalProperties False