From 6da2a0f861bbed9ffdb2cac35ef7b9a21379a12d Mon Sep 17 00:00:00 2001
From: Luke Sikina <lucas.skina@gmail.com>
Date: Wed, 10 Jan 2024 11:40:35 -0500
Subject: [PATCH] [ALS-5656] Make TimeSeriesProcessor handle missing concept
 paths

- In GIC land, we get queries that have a concept path that is present
in some other site, but not the one the query is getting run in
- The TimeseriesProcessor needs to not explode when this happens
---
 .../avillach/hpds/processing/AbstractProcessor.java | 13 +++++++++++++
 .../hpds/processing/TimeseriesProcessor.java        |  7 ++++---
 2 files changed, 17 insertions(+), 3 deletions(-)

diff --git a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/AbstractProcessor.java b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/AbstractProcessor.java
index 6323a400..8276e3bb 100644
--- a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/AbstractProcessor.java
+++ b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/AbstractProcessor.java
@@ -667,6 +667,19 @@ protected PhenoCube getCube(String path) {
 		}
 	}
 
+	/**
+	 * Get a cube without throwing an error if not found.
+	 * Useful for federated pic-sure's where there are fewer
+	 * guarantees about concept paths.
+	 */
+	protected Optional<PhenoCube<?>> nullableGetCube(String path) {
+		try {
+			return Optional.ofNullable(store.get(path));
+		} catch (InvalidCacheLoadException | ExecutionException e) {
+			return Optional.empty();
+		}
+	}
+
 	public TreeMap<String, ColumnMeta> getDictionary() {
 		return phenotypeMetaStore.getMetaStore();
 	}
diff --git a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/TimeseriesProcessor.java b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/TimeseriesProcessor.java
index dee9246e..e751901c 100644
--- a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/TimeseriesProcessor.java
+++ b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/TimeseriesProcessor.java
@@ -103,11 +103,12 @@ private void addDataForConcepts(Collection<String> pathList, Set<String> exporte
 				continue;
 			}
 			ArrayList<String[]> dataEntries = new ArrayList<String[]>();
-			PhenoCube<?> cube = abstractProcessor.getCube(conceptPath);
-			if(cube == null) {
-				log.warn("Attempting export of non-existant concept: " + conceptPath);
+			Optional<PhenoCube<?>> maybeCube = abstractProcessor.nullableGetCube(conceptPath);
+			if(maybeCube.isEmpty()) {
+				log.warn("Attempting export of non-existant concept: {}", conceptPath);
 				continue;
 			}
+			PhenoCube<?> cube = maybeCube.get();
 			log.debug("Exporting " + conceptPath);
 			List<?> valuesForKeys = cube.getValuesForKeys(idList);
 			for (Object kvObj : valuesForKeys) {