From edeaa5ba15683d44a16302f490beb16413b8ee7d Mon Sep 17 00:00:00 2001 From: Hong-Kit Randy Yeung Date: Tue, 18 Oct 2022 14:05:27 -0500 Subject: [PATCH] setting missing workflowType --- .../metadata/aggregator/MetadataAggregatorLambda.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/gov/nasa/cumulus/metadata/aggregator/MetadataAggregatorLambda.java b/src/main/java/gov/nasa/cumulus/metadata/aggregator/MetadataAggregatorLambda.java index 38a00f6..eea544b 100644 --- a/src/main/java/gov/nasa/cumulus/metadata/aggregator/MetadataAggregatorLambda.java +++ b/src/main/java/gov/nasa/cumulus/metadata/aggregator/MetadataAggregatorLambda.java @@ -48,6 +48,10 @@ public String PerformFunction(String input, Context context) throws Exception { String collectionVersion = (String) config.get("version"); Boolean rangeIs360 = (Boolean) config.get("rangeIs360"); JSONObject boundingBox = (JSONObject) config.get("boundingBox"); + /** call the setWorkFlowType by passing in the stateMachine name to set a WorkflowTypeEnum + * this will help the logic in postIngestProcess function. + */ + this.setWorkFlowType((String) config.get("stateMachine")); String isoRegex = (String)config.get("isoRegex"); String archiveXmlRegex = (String)config.get("archiveXmlRegex"); @@ -318,7 +322,7 @@ private void setCMRMetadataToProvider(String input) String provider = (String)config.get("provider"); CMRRestClientProvider.setProvider(provider); } - + public void setWorkFlowType(String stateMachine) throws ParseException { AdapterLogger.LogInfo("current state machine:" + stateMachine); if(StringUtils.endsWithIgnoreCase(stateMachine, "IngestWorkflow")) {