lsmyrnaios
/
dnet-hadoop
forked from D-Net/dnet-hadoop
1
0
Fork 0
Code Pull Requests Activity

Applying PR#512 - Sequential ActionSet promotion

This commit is contained in:
Claudio Atzori 2024-11-22 10:05:56 +01:00
parent 15227f82b8
commit 2e54715d71
1 changed files with 9 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -135,22 +135,10 @@
<arg>--outputPath</arg><arg>${workingDir}/action_payload_by_type</arg> <arg>--outputPath</arg><arg>${workingDir}/action_payload_by_type</arg>
<arg>--isLookupUrl</arg><arg>${isLookupUrl}</arg> <arg>--isLookupUrl</arg><arg>${isLookupUrl}</arg>
</spark> </spark>
<ok to="ForkPromote"/> <ok to="PromoteActionPayloadForDatasetTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </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"/>
<path start="PromoteActionPayloadForPersonTable"/>
</fork>
<action name="PromoteActionPayloadForDatasetTable"> <action name="PromoteActionPayloadForDatasetTable">
<sub-workflow> <sub-workflow>
<app-path>${wf:appPath()}/promote_action_payload_for_dataset_table</app-path> <app-path>${wf:appPath()}/promote_action_payload_for_dataset_table</app-path>
@ -162,7 +150,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForDatasourceTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -177,7 +165,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForOrganizationTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -192,7 +180,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForOtherResearchProductTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -207,7 +195,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForProjectTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -222,7 +210,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForPublicationTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -237,7 +225,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForRelationTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -252,7 +240,7 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="PromoteActionPayloadForSoftwareTable"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
@ -267,26 +255,9 @@
</property> </property>
</configuration> </configuration>
</sub-workflow> </sub-workflow>
<ok to="JoinPromote"/> <ok to="End"/>
<error to="Kill"/> <error to="Kill"/>
</action> </action>
<action name="PromoteActionPayloadForPersonTable">
<sub-workflow>
<app-path>${wf:appPath()}/promote_action_payload_for_person_table</app-path>
<propagate-configuration/>
<configuration>
<property>
<name>inputActionPayloadRootPath</name>
<value>${workingDir}/action_payload_by_type</value>
</property>
</configuration>
</sub-workflow>
<ok to="JoinPromote"/>
<error to="Kill"/>
</action>
<join name="JoinPromote" to="End"/>
<end name="End"/> <end name="End"/>
</workflow-app> </workflow-app>