You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datalab.apache.org by dy...@apache.org on 2022/11/17 14:17:19 UTC
[incubator-datalab] 03/03: fix status check for failed instances
This is an automated email from the ASF dual-hosted git repository.
dyankiv pushed a commit to branch epm-v2.5.2.1
in repository https://gitbox.apache.org/repos/asf/incubator-datalab.git
commit 230fdcb83c6c601900cf7749cbcdc50bc24d2fb4
Author: Denys Yankiv <de...@gmail.com>
AuthorDate: Thu Nov 17 16:16:01 2022 +0200
fix status check for failed instances
---
.../backendapi/schedulers/CheckInfrastructureStatusScheduler.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
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 e6a0b0e1d..43e55bbc1 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
@@ -51,7 +51,7 @@ import static com.epam.datalab.dto.UserInstanceStatus.*;
public class CheckInfrastructureStatusScheduler implements Job {
private static final List<UserInstanceStatus> statusesToCheck =
- Arrays.asList(STARTING, CREATING, RUNNING, STOPPING, RECONFIGURING, STOPPED, TERMINATING, TERMINATED);
+ Arrays.asList(STARTING, CREATING, RUNNING, STOPPING, RECONFIGURING, STOPPED, TERMINATING, TERMINATED, FAILED);
private final InfrastructureInfoService infrastructureInfoService;
private final SecurityService securityService;
@@ -81,7 +81,8 @@ public class CheckInfrastructureStatusScheduler implements Job {
.map(EndpointDTO::getName)
.collect(Collectors.toList());
- List<UserInstanceDTO> userInstanceDTOS = exploratoryDAO.fetchExploratoriesByEndpointWhereStatusIn(activeEndpoints, statusesToCheck, Boolean.TRUE);
+ List<UserInstanceDTO> userInstanceDTOS = exploratoryDAO.fetchExploratoriesByEndpointWhereStatusIn(activeEndpoints, statusesToCheck, Boolean.TRUE)
+ .stream().filter(e -> e.getInstanceId() != null).collect(Collectors.toList());
Map<String, List<EnvResource>> exploratoryAndSparkInstances = userInstanceDTOS
.stream()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datalab.apache.org
For additional commands, e-mail: commits-help@datalab.apache.org