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")) {