ALS-7132: Revert change breaking query sync for dataframes

hms-dbmi · Aug 21, 2024 · 8b7cf2b · 8b7cf2b
1 parent 1cdfd3e
commit 8b7cf2b
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/service/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/service/PicSureService.java b/service/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/service/PicSureService.java
@@ -296,6 +296,19 @@ private ResponseEntity _querySync(QueryRequest resultRequest) throws IOException
 
 		case DATAFRAME:
 		case SECRET_ADMIN_DATAFRAME:
+			QueryStatus status = query(resultRequest).getBody();
+			while (status.getResourceStatus().equalsIgnoreCase("RUNNING")
+					|| status.getResourceStatus().equalsIgnoreCase("PENDING")) {
+				status = queryStatus(UUID.fromString(status.getResourceResultId()), null);
+			}
+			log.info(status.toString());
+
+			AsyncResult result = queryService.getResultFor(status.getResourceResultId());
+			if (result.getStatus() == AsyncResult.Status.SUCCESS) {
+				result.getStream().open();
+				return queryOkResponse(new String(result.getStream().readAllBytes(), StandardCharsets.UTF_8), incomingQuery, MediaType.TEXT_PLAIN);
+			}
+			return ResponseEntity.status(400).contentType(MediaType.APPLICATION_JSON).body("Status : " + result.getStatus().name());
 
 		case CROSS_COUNT:
 			return queryOkResponse(countProcessor.runCrossCounts(incomingQuery), incomingQuery, MediaType.APPLICATION_JSON);