You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datalab.apache.org by of...@apache.org on 2020/11/20 10:35:17 UTC

[incubator-datalab] branch develop updated: [DATALAB-1895] Sync up DataLab instance statuses with cloud statuses

This is an automated email from the ASF dual-hosted git repository.

ofuks pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-datalab.git


The following commit(s) were added to refs/heads/develop by this push:
     new ac80bc9  [DATALAB-1895] Sync up DataLab instance statuses with cloud statuses
ac80bc9 is described below

commit ac80bc99b3ea832656cb0d3f456ab21f1e6d927e
Author: Oleh Fuks <ol...@gmail.com>
AuthorDate: Fri Nov 20 12:35:03 2020 +0200

    [DATALAB-1895] Sync up DataLab instance statuses with cloud statuses
---
 .../backendapi/schedulers/CheckInfrastructureStatusScheduler.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/services/self-service/src/main/java/com/epam/datalab/backendapi/schedulers/CheckInfrastructureStatusScheduler.java b/services/self-service/src/main/java/com/epam/datalab/backendapi/schedulers/CheckInfrastructureStatusScheduler.java
index de56486..3bd194c 100644
--- a/services/self-service/src/main/java/com/epam/datalab/backendapi/schedulers/CheckInfrastructureStatusScheduler.java
+++ b/services/self-service/src/main/java/com/epam/datalab/backendapi/schedulers/CheckInfrastructureStatusScheduler.java
@@ -81,7 +81,9 @@ public class CheckInfrastructureStatusScheduler implements Job {
 
 		Map<String, List<EnvResource>> exploratoryAndSparkInstances = userInstanceDTOS
 				.stream()
-				.collect(Collectors.toMap(UserInstanceDTO::getEndpoint, this::getExploratoryAndSparkInstances));
+				.map(this::getExploratoryAndSparkInstances)
+				.flatMap(Collection::stream)
+				.collect(Collectors.groupingBy(EnvResource::getEndpoint));
 
 		activeEndpoints.forEach(e -> {
 					List<EnvResource> hostInstances = Stream.of(getEdgeInstances(e), exploratoryAndSparkInstances.get(e))


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datalab.apache.org
For additional commands, e-mail: commits-help@datalab.apache.org