Project

General

Profile

« Previous | Next » 

Revision 46859

Added by Alessia Bardi over 7 years ago

Collection workflow refactored: no need two separate branches (refresh/incremental)

View differences:

modules/dnet-parthenos/trunk/src/main/resources/eu/dnetlib/bootstrap/profiles/workflows/collection_template.xml
22 22 
						<PARAM name="selection" ref="harvestingMode" />
23 23 
					</PARAMETERS>
24 24 
					<ARCS>
25 
						<ARC to="COLLECT_REFRESH" name="REFRESH" />
25 
						<ARC to="COLLECT" name="REFRESH" />
26 26 
						<ARC to="PREPARE_INCREMENTAL" name="INCREMENTAL" />
27 27 
					</ARCS>
28 28 
				</NODE>
29 
				<NODE name="COLLECT_REFRESH" type="CollectRecords">
30 
					<DESCRIPTION>Start Harvesting</DESCRIPTION>
31 
					<PARAMETERS>
32 
						<PARAM name="datasourceId" ref="dsId"/>
33 
						<PARAM name="datasourceInterface" ref="interface"/>
34 
						<PARAM name="eprParam" value="collected_epr"/>
35 
					</PARAMETERS>
36 
					<ARCS>
37 
						<ARC to="MD_BUILDER_REFRESH"/>
38 
					</ARCS>
39 
				</NODE>
40 
				<NODE name="MD_BUILDER_REFRESH" type="MdBuilder">
41 
					<DESCRIPTION>Prepare mdstore records</DESCRIPTION>
42 
					<PARAMETERS>
43 
						<PARAM name="inputEprParam" value="collected_epr"/>
44 
						<PARAM name="outputEprParam" value="store_epr"/>
45 
						<PARAM name="datasourceId" ref="dsId"/>
46 
						<PARAM name="datasourceName" ref="dsName"/>
47 
						<PARAM name="datasourceInterface" ref="interface"/>
48 
					</PARAMETERS>
49 
					<ARCS>
50 
						<ARC to="STORE_REFRESH"/>
51 
					</ARCS>
52 
				</NODE>
53 
				<NODE name="STORE_REFRESH" type="StoreMDStoreRecords">
54 
					<DESCRIPTION>Store mdstore records</DESCRIPTION>
55 
					<PARAMETERS>
56 
						<PARAM name="mdId" ref="collMdstoreId"/>
57 
						<PARAM name="storingType" value="REFRESH"/>
58 
						<PARAM name="eprParam" value="store_epr"/>
59 
					</PARAMETERS>
60 
					<ARCS>
61 
						<ARC to="UPDATE_INFO"/>
62 
					</ARCS>
63 
				</NODE>
64 

  		




  65
  
  
    
				<!-- Incremental branch -->


  		




  66
  29
  
    
				<NODE name="PREPARE_INCREMENTAL" type="FindDateRangeForIncrementalHarvesting">


  		




  67
  30
  
    
					<DESCRIPTION>Find Date Range For Incremental Harvesting</DESCRIPTION>


  		




  68
  31
  
    
					<PARAMETERS>


  		




  69
  
  
    
						<PARAM name="fromDateParam" value="FROM_DATE"/>


  		




  70
  
  
    
						<PARAM name="untilDateParam" value="UNTIL_DATE"/>


  		




  
  32
  
    
						<PARAM name="dateParam" value="FROM_DATE"/>


  		




  71
  33
  
    
					</PARAMETERS>


  		




  72
  34
  
    
					<ARCS>


  		




  73
  
  
    
						<ARC to="COLLECT_INCREMENTAL"/>


  		




  
  35
  
    
						<ARC to="COLLECT"/>


  		




  74
  36
  
    
					</ARCS>


  		




  75
  37
  
    
				</NODE>


  		




  76
  
  
    

  		




  77
  
  
    
				<NODE name="COLLECT_INCREMENTAL" type="DateRangeCollectRecords">


  		




  78
  
  
    
					<DESCRIPTION>Start incremental harvesting</DESCRIPTION>


  		




  
  38
  
    
				<NODE name="COLLECT" type="CollectRecords">


  		




  
  39
  
    
					<DESCRIPTION>Start Harvesting</DESCRIPTION>


  		




  79
  40
  
    
					<PARAMETERS>


  		




  80
  41
  
    
						<PARAM name="datasourceId" ref="dsId"/>


  		




  81
  42
  
    
						<PARAM name="datasourceInterface" ref="interface"/>


  		




  82
  43
  
    
						<PARAM name="eprParam" value="collected_epr"/>


  		




  83
  44
  
    
						<PARAM name="fromDate" env="FROM_DATE"/>


  		




  84
  
  
    
						<PARAM name="untilDate" env="UNTIL_DATE"/>


  		




  85
  
  
    

  		




  86
  
  
    
						<!--<PARAM required="true" type="string" name="fromDateParam" managedBy="system">FROM_DATE</PARAM>-->


  		




  87
  
  
    
						<!--<PARAM required="true" type="string" name="untilDateParam" managedBy="system">UNTIL_DATE</PARAM>-->


  		




  
  45
  
    
						<PARAM name="untilDate" value=""/>


  		




  88
  46
  
    
					</PARAMETERS>


  		




  89
  47
  
    
					<ARCS>


  		




  90
  
  
    
						<ARC to="MD_BUILDER_INCREMENTAL"/>


  		




  
  48
  
    
						<ARC to="MD_BUILDER"/>


  		




  91
  49
  
    
					</ARCS>


  		




  92
  50
  
    
				</NODE>


  		




  93
  
  
    

  		




  94
  
  
    
				<NODE name="MD_BUILDER_INCREMENTAL" type="MdBuilder">


  		




  
  51
  
    
				<NODE name="MD_BUILDER" type="MdBuilder">


  		




  95
  52
  
    
					<DESCRIPTION>Prepare mdstore records</DESCRIPTION>


  		




  96
  53
  
    
					<PARAMETERS>


  		




  97
  54
  
    
						<PARAM name="inputEprParam" value="collected_epr"/>


  		




  ......




  101
  58
  
    
						<PARAM name="datasourceInterface" ref="interface"/>


  		




  102
  59
  
    
					</PARAMETERS>


  		




  103
  60
  
    
					<ARCS>


  		




  104
  
  
    
						<ARC to="STORE_INCREMENTAL"/>


  		




  
  61
  
    
						<ARC to="STORE"/>


  		




  105
  62
  
    
					</ARCS>


  		




  106
  63
  
    
				</NODE>


  		




  107
  
  
    

  		




  108
  
  
    
				<NODE name="STORE_INCREMENTAL" type="StoreMDStoreRecords">


  		




  109
  
  
    
					<DESCRIPTION>Store mdstore records incrementally</DESCRIPTION>


  		




  
  64
  
    
				<NODE name="STORE" type="StoreMDStoreRecords">


  		




  
  65
  
    
					<DESCRIPTION>Store mdstore records</DESCRIPTION>


  		




  110
  66
  
    
					<PARAMETERS>


  		




  111
  67
  
    
						<PARAM name="mdId" ref="collMdstoreId"/>


  		




  112
  
  
    
						<PARAM name="storingType" value="INCREMENTAL"/>


  		




  
  68
  
    
						<PARAM name="storingType" ref="harvestingMode"/>


  		




  113
  69
  
    
						<PARAM name="eprParam" value="store_epr"/>


  		




  114
  70
  
    
					</PARAMETERS>


  		




  115
  71
  
    
					<ARCS>


  		




  ......




  131
  87
  
    
						<ARC to="success"/>


  		




  132
  88
  
    
					</ARCS>


  		




  133
  89
  
    
				</NODE>


  		




  134
  
  
    

  		




  135
  90
  
    
			</WORKFLOW>


  		




  136
  91
  
    
		</CONFIGURATION>


  		




  137
  92
  
    
	</BODY>


  		












Also available in:  Unified diff