Skip to content

Commit

Permalink
added a wf with a split
Browse files Browse the repository at this point in the history
  • Loading branch information
Fedor committed Aug 31, 2021
1 parent eacb6f5 commit b0a6436
Show file tree
Hide file tree
Showing 5 changed files with 81 additions and 1 deletion.
2 changes: 1 addition & 1 deletion configs/simpleBlock.xml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<configuration>
<module class="at.uibk.dps.ee.control.modules.EnactmentAgentModule"/>

<module class="at.uibk.dps.ee.io.modules.InputReaderFileModule">
<property name="filePath">./inputData/simpleBlock.json</property>
</module>
Expand Down
23 changes: 23 additions & 0 deletions configs/simpleSplit.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
<configuration>
<module class="at.uibk.dps.ee.control.modules.EnactmentVerticleModule">
<property name="pauseOnStart">false</property>
<property name="deploymentNumber">8</property>
</module>
<module class="at.uibk.dps.ee.io.modules.InputReaderFileModule">
<property name="filePath">./inputData/splitWf.json</property>
</module>
<module class="at.uibk.dps.ee.io.modules.OutputPrinterModule"/>
<module class="at.uibk.dps.ee.io.modules.SpecificationInputModule">
<property name="filePathAfcl">./demoWfs/splitWf.yaml</property>
<property name="filePathMappingFile">./typeMappings/simpleBlock.json</property>
</module>
<module class="at.uibk.dps.ee.visualization.modules.EnactmentViewerModule">
<property name="closeOnTerminate">false</property>
<property name="updatePeriodMs">100</property>
</module>
<module class="at.uibk.dps.sc.core.modules.SchedulerModule">
<property name="schedulingMode">SingleOption</property>
<property name="mappingsToPick">1</property>
<property name="sizeThresholdKb">10</property>
</module>
</configuration>
39 changes: 39 additions & 0 deletions demoWfs/splitWf.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,39 @@
---
name: "SimpleSplit"
dataIns:
- name: "arr1"
type: "collection"
source: "arr1"
workflowBody:
- parallelFor:
name: "f"
dataIns:
- name: "in"
type: "collection"
source: "SimpleSplit/arr1"
constraints:
- name: "split"
value: "2"
iterators: ["in"]
loopBody:
- function:
name: "a"
type: "SumCollection"
dataIns:
- name: "collectionToSum"
type: "collection"
source: "f/in"
- name: "waitTimeIn"
type: "number"
source: 1000
dataOuts:
- name: "collectionSum"
type: "number"
dataOuts:
- name: "result"
type: "collection"
source: "a/collectionSum"
dataOuts:
- name: "result"
type: "collection"
source: "f/result"
3 changes: 3 additions & 0 deletions inputData/splitWf.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
{
"arr1" : [1,2,3,4]
}
15 changes: 15 additions & 0 deletions launches/simpleSplit.launch
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<launchConfiguration type="org.eclipse.jdt.launching.localJavaApplication">
<listAttribute key="org.eclipse.debug.core.MAPPED_RESOURCE_PATHS">
<listEntry value="/EE-Guice/src/main/java/at/uibk/dps/ee/guice/starter/EeConfiguration.java"/>
</listAttribute>
<listAttribute key="org.eclipse.debug.core.MAPPED_RESOURCE_TYPES">
<listEntry value="1"/>
</listAttribute>
<booleanAttribute key="org.eclipse.jdt.launching.ATTR_USE_CLASSPATH_ONLY_JAR" value="false"/>
<booleanAttribute key="org.eclipse.jdt.launching.ATTR_USE_START_ON_FIRST_THREAD" value="true"/>
<stringAttribute key="org.eclipse.jdt.launching.MAIN_TYPE" value="at.uibk.dps.ee.guice.starter.EeConfiguration"/>
<stringAttribute key="org.eclipse.jdt.launching.MODULE_NAME" value="EE-Demo"/>
<stringAttribute key="org.eclipse.jdt.launching.PROGRAM_ARGUMENTS" value="configs/simpleSplit.xml"/>
<stringAttribute key="org.eclipse.jdt.launching.PROJECT_ATTR" value="EE-Demo"/>
</launchConfiguration>

0 comments on commit b0a6436

Please sign in to comment.