From 2f0c85eeb3adadf94fb2842076fdaf175d143e76 Mon Sep 17 00:00:00 2001
From: Claudio Atzori <claudio.atzori@isti.cnr.it>
Date: Tue, 17 Mar 2020 17:04:58 +0100
Subject: [PATCH] updated parameters for regular_all_steps worfklow, introduced
 flag 'reuseContent'

---
 .../regular_all_steps/oozie_app/workflow.xml  | 28 ++++++++++++++++---
 1 file changed, 24 insertions(+), 4 deletions(-)

diff --git a/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/migration/wfs/regular_all_steps/oozie_app/workflow.xml b/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/migration/wfs/regular_all_steps/oozie_app/workflow.xml
index dedfa3942..e990cdbad 100644
--- a/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/migration/wfs/regular_all_steps/oozie_app/workflow.xml
+++ b/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/migration/wfs/regular_all_steps/oozie_app/workflow.xml
@@ -9,6 +9,11 @@
             <name>graphBasePath</name>
             <description>the target path to store raw graph</description>
         </property>
+        <property>
+            <name>reuseContent</name>
+            <value>false</value>
+            <description>should import content from the aggregator or reuse a previous version</description>
+        </property>
         <property>
             <name>postgresURL</name>
             <description>the postgres URL to access to the database</description>
@@ -43,19 +48,34 @@
         </property>
     </parameters>
 
-	<start to="ResetWorkingPath"/>
+	<start to="ResetGraphPath"/>
 
     <kill name="Kill">
         <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
     </kill>
 
-    <action name="ResetWorkingPath">
+    <action name="ResetGraphPath">
         <fs>
-            <delete path='${workingPath}'/>
-            <mkdir path='${workingPath}'/>
             <delete path="'${graphBasePath}/graph_raw'"/>
             <mkdir path="'${graphBasePath}/graph_raw'"/>
         </fs>
+        <ok to="ReuseContent"/>
+        <error to="Kill"/>
+    </action>
+
+    <decision name="ReuseContent">
+        <switch>
+            <case to="ResetWorkingPath">${wf:conf('reuseContent') eq false}</case>
+            <case to="GenerateEntities">${wf:conf('reuseContent') eq true}</case>
+            <default to="ResetWorkingPath"/>
+        </switch>
+    </decision>
+
+    <action name="ResetWorkingPath">
+        <fs>
+            <delete path="'${workingPath}'"/>
+            <mkdir path="'${workingPath}'"/>
+        </fs>
         <ok to="ImportDB"/>
         <error to="Kill"/>
     </action>