Project

General

Profile

« Previous | Next » 

Revision 58107

generic OAF compatible aggregation workflow, dedicated to the [Intersection] use case (set DataInfo.invisible = true)

View differences:

modules/dnet-openaireplus-workflows/trunk/src/main/resources/eu/dnetlib/test/profiles/openaireplus/workflows/repo-hi/Aggregate_Metadata_from_AggregatorPubsRepository_Intersection.xml
1
<?xml version="1.0" encoding="UTF-8"?>
2
<RESOURCE_PROFILE>
3
	<HEADER>
4
		<RESOURCE_IDENTIFIER
5
				value="653aa5a0-5461-4fe0-8a46-e5aabaabc8bf_V29ya2Zsb3dEU1Jlc291cmNlcy9Xb3JrZmxvd0RTUmVzb3VyY2VUeXBl"/>
6
		<RESOURCE_TYPE value="WorkflowDSResourceType"/>
7
		<RESOURCE_KIND value="WorkflowDSResources"/>
8
		<RESOURCE_URI value=""/>
9
		<DATE_OF_CREATION value="2015-12-11T15:43:51.0Z"/>
10
	</HEADER>
11
	<BODY>
12
		<WORKFLOW_NAME>Aggregate Metadata (publications) from Aggregator::PubsRepository [Intersection]</WORKFLOW_NAME>
13
		<WORKFLOW_INFO>
14
			<FIELD name="Action">Aggregate Metadata</FIELD>
15
			<FIELD name="Consequence IS">Intersection</FIELD>
16
			<FIELD name="Datasource class">Aggregator::PubsRepository</FIELD>
17
			<FIELD name="Content">publications</FIELD>
18
		</WORKFLOW_INFO>
19
		<WORKFLOW_TYPE>REPO_HI</WORKFLOW_TYPE>
20
		<WORKFLOW_PRIORITY>20</WORKFLOW_PRIORITY>
21
		<CONFIGURATION start="manual">
22
			<NODE name="VerifyDatasource" type="VerifyDatasource" isStart="true">
23
				<DESCRIPTION>Verify if DS is pending</DESCRIPTION>
24
				<PARAMETERS>
25
					<PARAM name="expectedInterfaceTypologyPrefixes" managedBy="system" required="false" type="string">aggregator::pubsrepository,pubscatalogue
26
					</PARAM>
27
					<PARAM name="expectedCompliancePrefixes" managedBy="system" required="false" type="string"></PARAM>
28
				</PARAMETERS>
29
				<ARCS>
30
					<ARC to="createMetaWf"/>
31
					<ARC to="validateDs" name="validateDs"/>
32
				</ARCS>
33
			</NODE>
34

  
35
			<NODE name="validateDs" type="ValidateDatasource">
36
				<DESCRIPTION>Validate DS</DESCRIPTION>
37
				<PARAMETERS/>
38
				<ARCS>
39
					<ARC to="createMetaWf"/>
40
				</ARCS>
41
			</NODE>
42

  
43
			<NODE name="createMetaWf" type="RegisterMetaWf">
44
				<DESCRIPTION>Create MetaWorkflow</DESCRIPTION>
45
				<PARAMETERS>
46
					<PARAM name="wfName" managedBy="system" required="true"
47
					       type="string">Aggregate Metadata (publications) from Aggregator::PubsRepository [Support]
48
					</PARAM>
49
				</PARAMETERS>
50
				<ARCS>
51
					<ARC to="createDc"/>
52
					<ARC to="createOaf"/>
53
				</ARCS>
54
			</NODE>
55

  
56
			<NODE name="createDc" type="CreateMDStore">
57
				<DESCRIPTION>Create oai_dc store</DESCRIPTION>
58
				<PARAMETERS>
59
					<PARAM name="format" managedBy="system" required="true" type="string">oai_dc</PARAM>
60
					<PARAM name="interpretation" managedBy="system" required="true" type="string">native</PARAM>
61
					<PARAM name="layout" managedBy="system" required="true" type="string">store</PARAM>
62
					<PARAM name="outputPrefix" managedBy="system" required="true" type="string">harv_</PARAM>
63
				</PARAMETERS>
64
				<ARCS>
65
					<ARC to="updateMetaWf"/>
66
				</ARCS>
67
			</NODE>
68
			<NODE name="createOaf" type="CreateMDStore">
69
				<DESCRIPTION>Create OAF store</DESCRIPTION>
70
				<PARAMETERS>
71
					<PARAM name="format" managedBy="system" required="true" type="string">OAF</PARAM>
72
					<PARAM name="interpretation" managedBy="system" required="true" type="string">intersection</PARAM>
73
					<PARAM name="layout" managedBy="system" required="true" type="string">store</PARAM>
74
					<PARAM name="outputPrefix" managedBy="system" required="true" type="string">tran_</PARAM>
75
				</PARAMETERS>
76
				<ARCS>
77
					<ARC to="updateMetaWf"/>
78
				</ARCS>
79
			</NODE>
80

  
81
			<NODE name="updateMetaWf" type="UpdateMetaWf" isJoin="true">
82
				<DESCRIPTION>Create MetaWorkflow</DESCRIPTION>
83
				<PARAMETERS>
84
					<PARAM name="beanName" managedBy="system" required="true" type="string">metaWfAggregatorPubsRepositoryIngestion</PARAM>
85
				</PARAMETERS>
86
				<ARCS>
87
					<ARC to="updateMetaWfStatus"/>
88
				</ARCS>
89
			</NODE>
90

  
91
			<NODE name="updateMetaWfStatus" type="UpdateOpenaireMetaWfStatus">
92
				<DESCRIPTION>Update MetaWorkflow Status</DESCRIPTION>
93
				<PARAMETERS/>
94
				<ARCS>
95
					<ARC to="success"/>
96
				</ARCS>
97
			</NODE>
98
		</CONFIGURATION>
99

  
100
		<STATUS/>
101
	</BODY>
102
</RESOURCE_PROFILE>
modules/dnet-openaireplus-workflows/trunk/src/main/resources/eu/dnetlib/test/profiles/openaireplus/workflows/repo-hi/Aggregate_Metadata_OAF_Intersection.xml
1
<?xml version="1.0" encoding="UTF-8"?>
2
<RESOURCE_PROFILE>
3
	<HEADER>
4
		<RESOURCE_IDENTIFIER
5
				value="653aa5a0-5461-4fe0-8a46-e5aabaabc8bf_V29ya2Zsb3dEU1Jlc291cmNlcy9Xb3JrZmxvd0RTUmVzb3VyY2VUeXBl"/>
6
		<RESOURCE_TYPE value="WorkflowDSResourceType"/>
7
		<RESOURCE_KIND value="WorkflowDSResources"/>
8
		<RESOURCE_URI value=""/>
9
		<DATE_OF_CREATION value="2015-12-11T15:43:51.0Z"/>
10
	</HEADER>
11
	<BODY>
12
		<WORKFLOW_NAME>Aggregate Metadata (OAF results) [Intersection]</WORKFLOW_NAME>
13
		<WORKFLOW_INFO>
14
			<FIELD name="Action">Aggregate Metadata</FIELD>
15
			<FIELD name="Consequence IS">Intersection</FIELD>
16
			<FIELD name="Datasource class"></FIELD>
17
			<FIELD name="Content">results</FIELD>
18
		</WORKFLOW_INFO>
19
		<WORKFLOW_TYPE>REPO_HI</WORKFLOW_TYPE>
20
		<WORKFLOW_PRIORITY>20</WORKFLOW_PRIORITY>
21
		<CONFIGURATION start="manual">
22
			<NODE name="VerifyDatasource" type="VerifyDatasource" isStart="true">
23
				<DESCRIPTION>Verify if DS is pending</DESCRIPTION>
24
				<PARAMETERS>
25
					<PARAM name="expectedInterfaceTypologyPrefixes" managedBy="system" required="false" type="string"></PARAM>
26
					<PARAM name="expectedCompliancePrefixes" managedBy="system" required="false" type="string"></PARAM>
27
				</PARAMETERS>
28
				<ARCS>
29
					<ARC to="createMetaWf"/>
30
					<ARC to="validateDs" name="validateDs"/>
31
				</ARCS>
32
			</NODE>
33

  
34
			<NODE name="validateDs" type="ValidateDatasource">
35
				<DESCRIPTION>Validate DS</DESCRIPTION>
36
				<PARAMETERS/>
37
				<ARCS>
38
					<ARC to="createMetaWf"/>
39
				</ARCS>
40
			</NODE>
41

  
42
			<NODE name="createMetaWf" type="RegisterMetaWf">
43
				<DESCRIPTION>Create MetaWorkflow</DESCRIPTION>
44
				<PARAMETERS>
45
					<PARAM name="wfName" managedBy="system" required="true"
46
					       type="string">Aggregate Metadata (OAF results) [Intersection]</PARAM>
47
				</PARAMETERS>
48
				<ARCS>
49
					<ARC to="createDc"/>
50
					<ARC to="createOaf"/>
51
				</ARCS>
52
			</NODE>
53

  
54
			<NODE name="createDc" type="CreateMDStore">
55
				<DESCRIPTION>Create oai_dc store</DESCRIPTION>
56
				<PARAMETERS>
57
					<PARAM name="format" managedBy="system" required="true" type="string">oai_dc</PARAM>
58
					<PARAM name="interpretation" managedBy="system" required="true" type="string">native</PARAM>
59
					<PARAM name="layout" managedBy="system" required="true" type="string">store</PARAM>
60
					<PARAM name="outputPrefix" managedBy="system" required="true" type="string">harv_</PARAM>
61
				</PARAMETERS>
62
				<ARCS>
63
					<ARC to="updateMetaWf"/>
64
				</ARCS>
65
			</NODE>
66
			<NODE name="createOaf" type="CreateMDStore">
67
				<DESCRIPTION>Create OAF store</DESCRIPTION>
68
				<PARAMETERS>
69
					<PARAM name="format" managedBy="system" required="true" type="string">OAF</PARAM>
70
					<PARAM name="interpretation" managedBy="system" required="true" type="string">intersection</PARAM>
71
					<PARAM name="layout" managedBy="system" required="true" type="string">store</PARAM>
72
					<PARAM name="outputPrefix" managedBy="system" required="true" type="string">tran_</PARAM>
73
				</PARAMETERS>
74
				<ARCS>
75
					<ARC to="updateMetaWf"/>
76
				</ARCS>
77
			</NODE>
78

  
79
			<NODE name="updateMetaWf" type="UpdateMetaWf" isJoin="true">
80
				<DESCRIPTION>Create MetaWorkflow</DESCRIPTION>
81
				<PARAMETERS>
82
					<PARAM name="beanName" managedBy="system" required="true" type="string">metaWfPubsRepository</PARAM>
83
				</PARAMETERS>
84
				<ARCS>
85
					<ARC to="updateMetaWfStatus"/>
86
				</ARCS>
87
			</NODE>
88

  
89
			<NODE name="updateMetaWfStatus" type="UpdateOpenaireMetaWfStatus">
90
				<DESCRIPTION>Update MetaWorkflow Status</DESCRIPTION>
91
				<PARAMETERS/>
92
				<ARCS>
93
					<ARC to="success"/>
94
				</ARCS>
95
			</NODE>
96
		</CONFIGURATION>
97

  
98
		<STATUS/>
99
	</BODY>
100
</RESOURCE_PROFILE>

Also available in: Unified diff