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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
