dhp-workflows/dhp-actionmanager/src/main/resources/eu/dnetlib/dhp/actionmanager/wf/main/oozie_app/workflow.xml

@@ -135,10 +135,21 @@
             <arg>--outputPath</arg><arg>${workingDir}/action_payload_by_type</arg>
             <arg>--isLookupUrl</arg><arg>${isLookupUrl}</arg>
         </spark>
-        <ok to="PromoteActionPayloadForDatasetTable"/>
+        <ok to="ForkPromote"/>
         <error to="Kill"/>
     </action>
 
+    <fork name="ForkPromote">
+        <path start="PromoteActionPayloadForDatasetTable"/>
+        <path start="PromoteActionPayloadForDatasourceTable"/>
+        <path start="PromoteActionPayloadForOrganizationTable"/>
+        <path start="PromoteActionPayloadForOtherResearchProductTable"/>
+        <path start="PromoteActionPayloadForProjectTable"/>
+        <path start="PromoteActionPayloadForPublicationTable"/>
+        <path start="PromoteActionPayloadForRelationTable"/>
+        <path start="PromoteActionPayloadForSoftwareTable"/>
+    </fork>
+
     <action name="PromoteActionPayloadForDatasetTable">
         <sub-workflow>
             <app-path>${wf:appPath()}/promote_action_payload_for_dataset_table</app-path>
@@ -150,7 +161,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForDatasourceTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -165,7 +176,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForOrganizationTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -180,7 +191,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForOtherResearchProductTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -195,7 +206,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForProjectTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -210,7 +221,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForPublicationTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -225,7 +236,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForRelationTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -240,7 +251,7 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="PromoteActionPayloadForSoftwareTable"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
@@ -255,9 +266,11 @@
                 </property>
             </configuration>
         </sub-workflow>
-        <ok to="End"/>
+        <ok to="JoinPromote"/>
         <error to="Kill"/>
     </action>
 
+    <join name="JoinPromote" to="End"/>
+
     <end name="End"/>
 </workflow-app>