[IOTA-36] Fixing bug when checkpointing
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
index 3bf0eb8..5577ea6 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
@@ -137,6 +137,7 @@
file.delete()
}
ORCHESTRATION_CACHE.orchestration_metadata.remove(orchestrationID)
+ ORCHESTRATION_CACHE.orchestration_globals.remove(orchestrationID)
ORCHESTRATION_CACHE.orchestration_name.remove(orchestrationID)
}
case Some(orch) =>
@@ -145,10 +146,13 @@
case Some(metadata) =>
val ensembleJSON = metadata.map(ensenble => ensenble._2)
val name: String = ORCHESTRATION_CACHE.orchestration_name.getOrElse(orchestrationID, "NOT SAVED")
+ val globals = ORCHESTRATION_CACHE.orchestration_globals.getOrElse(orchestrationID, HashMap.empty).map(global => global._2)
+
val orchestrationSpec = Json.obj(JSON_PATH.GUID -> orchestrationID,
JSON_PATH.COMMAND -> "RECREATE",
JSON_PATH.ORCHESTRATION_NAME -> name,
JSON_PATH.ORCHESTRATION_TIMESTAMP -> System.currentTimeMillis.toString,
+ JSON_PATH.GLOBAL_PERFORMERS -> globals,
JSON_PATH.ENSEMBLES -> ensembleJSON
)
