This is an automated email from the ASF dual-hosted git repository. dyankiv pushed a commit to branch DATALAB-2838 in repository https://gitbox.apache.org/repos/asf/incubator-datalab.git
commit 1bab4739cb627d0f6acb23591ce63c653217a0e7 Author: Denys Yankiv <[email protected]> AuthorDate: Wed Aug 17 14:56:10 2022 +0300 filter instances with id null --- .../backendapi/schedulers/CheckInfrastructureStatusScheduler.java | 3 ++- 1 file changed, 2 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 e6a0b0e1d..40ae7f4af 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,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]
