Project

General

Profile

« Previous | Next » 

Revision 35048

Added by Marek Horst over 9 years ago

#1176 introducing side products removal in common import by maintaining remove_sideproducts flag set to true by default.
Notice: do not provide any output directory location pointing to workingDir subdirectory!

View differences:

modules/icm-iis-mainworkflows/trunk/src/main/resources/eu/dnetlib/iis/mainworkflows/common/import/oozie_app/workflow.xml
221 221
			<name>output_project_concept</name>
222 222
			<description>project concepts output directory</description>
223 223
		</property>
224
		<property>
225
            <name>remove_sideproducts</name>
226
            <value>true</value>
227
            <description>flag indicating whole workingDir will be erased.
228
            Notice: do not provide any output directory location pointing to workingDir subdirectory!</description>
229
        </property>
224 230
	</parameters>
225 231
	
226 232
	<global>
......
746 752
            <configuration>
747 753
            	<property>
748 754
                    <name>workingDir</name>
749
                    <value>${workingDir}/ingest_pmc_plaintext/working_dir</value>
755
                    <value>	/working_dir</value>
750 756
                </property>
751 757
                <property>
752 758
					<name>input_document_nlm</name>
......
1236 1242
        <error to="fail"/>
1237 1243
    </action>
1238 1244

  
1239
	<join name="import_joining" to="end"/>
1245
	<join name="import_joining" to="finalize"/>
1240 1246
    
1247
    <decision name="finalize">
1248
		<switch>
1249
			<case to="remove_sideproducts">${remove_sideproducts eq "true"}</case>
1250
			<default to="end" />
1251
		</switch>
1252
	</decision>
1253
	
1254
	<action name="remove_sideproducts">
1255
		<fs>
1256
			<delete path="${nameNode}${workingDir}" />
1257
		</fs>
1258
		<ok to="end" />
1259
		<error to="fail" />
1260
	</action>
1261
    
1241 1262
	<kill name="fail">
1242 1263
		<message>Unfortunately, the process failed -- error message:
1243 1264
			[${wf:errorMessage(wf:lastErrorNode())}]</message>

Also available in: Unified diff