You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dlab.apache.org by of...@apache.org on 2019/11/12 12:13:45 UTC
[incubator-dlab] 01/01: [DLAB-1256] Fixed issue with stopping
notebook
This is an automated email from the ASF dual-hosted git repository.
ofuks pushed a commit to branch DLAB-1256
in repository https://gitbox.apache.org/repos/asf/incubator-dlab.git
commit 8a6df766c91eadd74de5643c185edb8199f3ff8f
Author: Oleh Fuks <ol...@gmail.com>
AuthorDate: Tue Nov 12 14:13:28 2019 +0200
[DLAB-1256] Fixed issue with stopping notebook
---
.../schedulers/CheckUserQuoteScheduler.java | 2 +-
.../backendapi/service/EnvironmentService.java | 2 ++
.../dlab/backendapi/service/SecurityService.java | 4 ++-
.../backendapi/service/SecurityServiceImpl.java | 5 ++--
.../service/impl/EnvironmentServiceImpl.java | 20 ++++++++++++--
.../service/impl/SchedulerJobServiceImpl.java | 10 +++----
.../schedulers/CheckUserQuoteSchedulerTest.java | 4 +--
.../service/impl/EnvironmentServiceImplTest.java | 17 +++++-------
.../service/impl/SchedulerJobServiceImplTest.java | 32 +++++++++++-----------
9 files changed, 56 insertions(+), 40 deletions(-)
diff --git a/services/self-service/src/main/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteScheduler.java b/services/self-service/src/main/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteScheduler.java
index ce3b009..1e2e7f4 100644
--- a/services/self-service/src/main/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteScheduler.java
+++ b/services/self-service/src/main/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteScheduler.java
@@ -44,6 +44,6 @@ public class CheckUserQuoteScheduler implements Job {
.map(UserDTO::getName)
.filter(billingDAO::isUserQuoteReached)
.peek(u -> log.warn("Stopping {} user env because of reaching user billing quote", u))
- .forEach(environmentService::stopEnvironment);
+ .forEach(environmentService::stopEnvironmentWithServiceAccount);
}
}
diff --git a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/EnvironmentService.java b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/EnvironmentService.java
index e36d936..65953cd 100644
--- a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/EnvironmentService.java
+++ b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/EnvironmentService.java
@@ -37,6 +37,8 @@ public interface EnvironmentService {
void stopEnvironment(String user);
+ void stopEnvironmentWithServiceAccount(String user);
+
void stopProjectEnvironment(String project);
void stopEdge(String user);
diff --git a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityService.java b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityService.java
index d402545..699557f 100644
--- a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityService.java
+++ b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityService.java
@@ -23,6 +23,8 @@ import com.epam.dlab.auth.UserInfo;
public interface SecurityService {
UserInfo getUserInfo(String code);
+
UserInfo getUserInfoOffline(String username);
- UserInfo getServiceAccountInfo(String username);
+
+ UserInfo getServiceAccountInfo();
}
diff --git a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityServiceImpl.java b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityServiceImpl.java
index db41a13..9357929 100644
--- a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityServiceImpl.java
+++ b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/SecurityServiceImpl.java
@@ -57,8 +57,9 @@ public class SecurityServiceImpl implements SecurityService {
}
@Override
- public UserInfo getServiceAccountInfo(String username) {
+ public UserInfo getServiceAccountInfo() {
AccessTokenResponse accessTokenResponse = keycloakService.generateServiceAccountToken();
- return new UserInfo(username, accessTokenResponse.getToken());
+ return new UserInfo(KeycloakUtil.parseToken(accessTokenResponse.getToken()).getPreferredUsername(),
+ accessTokenResponse.getToken());
}
}
diff --git a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImpl.java b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImpl.java
index 5737497..f062c7f 100644
--- a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImpl.java
+++ b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImpl.java
@@ -122,15 +122,24 @@ public class EnvironmentServiceImpl implements EnvironmentService {
}
@Override
+ public void stopEnvironmentWithServiceAccount(String user) {
+ log.debug("Stopping environment for user {} by scheduler", user);
+ checkState(user, "stop");
+ exploratoryDAO.fetchRunningExploratoryFields(user)
+ .forEach(this::stopNotebookWithServiceAccount);
+ stopEdge(user);
+ }
+
+ @Override
public void stopProjectEnvironment(String project) {
log.debug("Stopping environment for project {}", project);
checkProjectResourceConditions(project, "stop");
exploratoryDAO.fetchRunningExploratoryFieldsForProject(project)
- .forEach(this::stopNotebook);
+ .forEach(this::stopNotebookWithServiceAccount);
projectService.get(project).getEndpoints().stream()
.filter(e -> UserInstanceStatus.RUNNING == e.getStatus())
- .forEach(endpoint -> projectService.stop(securityService.getServiceAccountInfo("admin"),
+ .forEach(endpoint -> projectService.stop(securityService.getServiceAccountInfo(),
endpoint.getName(), project));
}
@@ -196,7 +205,12 @@ public class EnvironmentServiceImpl implements EnvironmentService {
}
private void stopNotebook(UserInstanceDTO instance) {
- final UserInfo userInfo = securityService.getServiceAccountInfo(instance.getUser());
+ final UserInfo userInfo = securityService.getUserInfoOffline(instance.getUser());
+ exploratoryService.stop(userInfo, instance.getExploratoryName());
+ }
+
+ private void stopNotebookWithServiceAccount(UserInstanceDTO instance) {
+ final UserInfo userInfo = securityService.getServiceAccountInfo();
exploratoryService.stop(userInfo, instance.getExploratoryName());
}
diff --git a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImpl.java b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImpl.java
index 7f3d3d8..2d67665 100644
--- a/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImpl.java
+++ b/services/self-service/src/main/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImpl.java
@@ -207,14 +207,14 @@ public class SchedulerJobServiceImpl implements SchedulerJobService {
final String compName = job.getComputationalName();
final String user = job.getUser();
log.debug("Stopping exploratory {} computational {} for user {} by scheduler", expName, compName, user);
- computationalService.stopSparkCluster(securityService.getServiceAccountInfo(job.getUser()), expName, compName);
+ computationalService.stopSparkCluster(securityService.getServiceAccountInfo(), expName, compName);
}
private void terminateComputational(SchedulerJobData job) {
final String user = job.getUser();
final String expName = job.getExploratoryName();
final String compName = job.getComputationalName();
- final UserInfo userInfo = securityService.getServiceAccountInfo(user);
+ final UserInfo userInfo = securityService.getServiceAccountInfo();
log.debug("Terminating exploratory {} computational {} for user {} by scheduler", expName, compName, user);
computationalService.terminateComputational(userInfo, expName, compName);
}
@@ -223,7 +223,7 @@ public class SchedulerJobServiceImpl implements SchedulerJobService {
final String expName = job.getExploratoryName();
final String user = job.getUser();
log.debug("Stopping exploratory {} for user {} by scheduler", expName, user);
- exploratoryService.stop(securityService.getServiceAccountInfo(user), expName);
+ exploratoryService.stop(securityService.getServiceAccountInfo(), expName);
}
private List<SchedulerJobData> getExploratorySchedulersForTerminating(OffsetDateTime now) {
@@ -245,7 +245,7 @@ public class SchedulerJobServiceImpl implements SchedulerJobService {
final String exploratoryName = schedulerJobData.getExploratoryName();
final String project = schedulerJobData.getProject();
log.debug("Starting exploratory {} for user {} by scheduler", exploratoryName, user);
- exploratoryService.start(securityService.getServiceAccountInfo(user), exploratoryName, project);
+ exploratoryService.start(securityService.getServiceAccountInfo(), exploratoryName, project);
if (schedulerJobData.getJobDTO().isSyncStartRequired()) {
log.trace("Starting computational for exploratory {} for user {} by scheduler", exploratoryName, user);
final DataEngineType sparkCluster = DataEngineType.SPARK_STANDALONE;
@@ -268,7 +268,7 @@ public class SchedulerJobServiceImpl implements SchedulerJobService {
private void startSpark(String user, String expName, String compName, String project) {
log.debug("Starting exploratory {} computational {} for user {} by scheduler", expName, compName, user);
- computationalService.startSparkCluster(securityService.getServiceAccountInfo(user), expName, compName, project);
+ computationalService.startSparkCluster(securityService.getServiceAccountInfo(), expName, compName, project);
}
private boolean shouldClusterBeStarted(DataEngineType sparkCluster, UserComputationalResource compResource) {
diff --git a/services/self-service/src/test/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteSchedulerTest.java b/services/self-service/src/test/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteSchedulerTest.java
index d858573..1c6937c 100644
--- a/services/self-service/src/test/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteSchedulerTest.java
+++ b/services/self-service/src/test/java/com/epam/dlab/backendapi/schedulers/CheckUserQuoteSchedulerTest.java
@@ -56,7 +56,7 @@ public class CheckUserQuoteSchedulerTest {
verify(environmentService).getUsers();
verify(billingDAO).isUserQuoteReached(USER);
- verify(environmentService).stopEnvironment(USER);
+ verify(environmentService).stopEnvironmentWithServiceAccount(USER);
verifyNoMoreInteractions(environmentService, billingDAO);
verifyZeroInteractions(jobExecutionContext);
}
@@ -70,7 +70,7 @@ public class CheckUserQuoteSchedulerTest {
verify(environmentService).getUsers();
verify(billingDAO).isUserQuoteReached(USER);
- verify(environmentService, never()).stopEnvironment(anyString());
+ verify(environmentService, never()).stopEnvironmentWithServiceAccount(anyString());
verifyNoMoreInteractions(environmentService, billingDAO);
verifyZeroInteractions(jobExecutionContext);
}
diff --git a/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImplTest.java b/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImplTest.java
index 212cdf7..3344ad3 100644
--- a/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImplTest.java
+++ b/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/EnvironmentServiceImplTest.java
@@ -146,7 +146,6 @@ public class EnvironmentServiceImplTest {
final UserInfo userInfo = getUserInfo();
when(exploratoryDAO.fetchRunningExploratoryFields(anyString())).thenReturn(getUserInstances());
when(securityService.getUserInfoOffline(anyString())).thenReturn(userInfo);
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(userInfo);
when(exploratoryService.stop(any(UserInfo.class), anyString())).thenReturn(UUID);
when(keyDAO.getEdgeStatus(anyString())).thenReturn(RUNNING_STATE);
when(edgeService.stop(any(UserInfo.class))).thenReturn(UUID);
@@ -154,8 +153,7 @@ public class EnvironmentServiceImplTest {
environmentService.stopEnvironment(USER);
verify(exploratoryDAO).fetchRunningExploratoryFields(USER);
- verify(securityService, times(1)).getUserInfoOffline(USER);
- verify(securityService, times(2)).getServiceAccountInfo(USER);
+ verify(securityService, times(3)).getUserInfoOffline(USER);
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_1));
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_2));
verify(keyDAO, times(2)).getEdgeStatus(USER);
@@ -189,7 +187,7 @@ public class EnvironmentServiceImplTest {
public void stopEnvironmentWithoutEdge() {
final UserInfo userInfo = getUserInfo();
when(exploratoryDAO.fetchRunningExploratoryFields(anyString())).thenReturn(getUserInstances());
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(userInfo);
+ when(securityService.getUserInfoOffline(anyString())).thenReturn(userInfo);
when(exploratoryService.stop(any(UserInfo.class), anyString())).thenReturn(UUID);
when(keyDAO.getEdgeStatus(anyString())).thenReturn(STOPPED_STATE);
when(edgeService.stop(any(UserInfo.class))).thenReturn(UUID);
@@ -197,7 +195,7 @@ public class EnvironmentServiceImplTest {
environmentService.stopEnvironment(USER);
verify(exploratoryDAO).fetchRunningExploratoryFields(USER);
- verify(securityService, times(2)).getServiceAccountInfo(USER);
+ verify(securityService, times(2)).getUserInfoOffline(USER);
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_1));
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_2));
verify(keyDAO, times(2)).getEdgeStatus(USER);
@@ -213,7 +211,7 @@ public class EnvironmentServiceImplTest {
final UserInfo userInfo = getUserInfo();
final ProjectDTO projectDTO = getProjectDTO();
when(exploratoryDAO.fetchRunningExploratoryFieldsForProject(anyString())).thenReturn(getUserInstances());
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(userInfo);
+ when(securityService.getServiceAccountInfo()).thenReturn(userInfo);
when(exploratoryService.stop(any(UserInfo.class), anyString())).thenReturn(UUID);
when(projectService.get(anyString())).thenReturn(projectDTO);
doNothing().when(projectService).stop(any(UserInfo.class), anyString(), anyString());
@@ -223,8 +221,7 @@ public class EnvironmentServiceImplTest {
verify(exploratoryDAO).fetchRunningExploratoryFieldsForProject(PROJECT_NAME);
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_1));
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_2));
- verify(securityService, times(2)).getServiceAccountInfo(USER);
- verify(securityService).getServiceAccountInfo(ADMIN);
+ verify(securityService, times(3)).getServiceAccountInfo();
verify(projectService).get(eq(PROJECT_NAME));
verify(projectService).stop(refEq(userInfo), eq(ENDPOINT_NAME), eq(PROJECT_NAME));
verify(exploratoryDAO).fetchProjectExploratoriesWhereStatusIn(PROJECT_NAME, Arrays.asList(UserInstanceStatus.CREATING,
@@ -262,12 +259,12 @@ public class EnvironmentServiceImplTest {
@Test
public void stopExploratory() {
final UserInfo userInfo = getUserInfo();
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(userInfo);
+ when(securityService.getUserInfoOffline(anyString())).thenReturn(userInfo);
when(exploratoryService.stop(any(UserInfo.class), anyString())).thenReturn(UUID);
environmentService.stopExploratory(USER, EXPLORATORY_NAME_1);
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getUserInfoOffline(USER);
verify(exploratoryService).stop(refEq(userInfo), eq(EXPLORATORY_NAME_1));
verifyNoMoreInteractions(securityService, exploratoryService);
}
diff --git a/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImplTest.java b/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImplTest.java
index 8a7d8ec..0cd0cd3 100644
--- a/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImplTest.java
+++ b/services/self-service/src/test/java/com/epam/dlab/backendapi/service/impl/SchedulerJobServiceImplTest.java
@@ -392,11 +392,11 @@ public class SchedulerJobServiceImplTest {
LocalDateTime.of(LocalDate.now(),
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), false, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES))));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
schedulerJobService.startComputationalByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO)
.getComputationalSchedulerDataWithOneOfStatus(RUNNING, DataEngineType.SPARK_STANDALONE, STOPPED);
verify(computationalService).startSparkCluster(refEq(getUserInfo()), eq(EXPLORATORY_NAME),
@@ -492,11 +492,11 @@ public class SchedulerJobServiceImplTest {
LocalDateTime.of(LocalDate.now(),
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), false, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES))));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
schedulerJobService.stopComputationalByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO)
.getComputationalSchedulerDataWithOneOfStatus(RUNNING, DataEngineType.SPARK_STANDALONE, RUNNING);
verify(computationalService).stopSparkCluster(refEq(getUserInfo()), eq(EXPLORATORY_NAME),
@@ -590,11 +590,11 @@ public class SchedulerJobServiceImplTest {
LocalDateTime.of(LocalDate.now(),
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), false, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES))));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
schedulerJobService.stopExploratoryByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO).getExploratorySchedulerWithStatusAndClusterLastActivityLessThan(eq(RUNNING),
any(Date.class));
verify(exploratoryService).stop(refEq(getUserInfo()), eq(EXPLORATORY_NAME));
@@ -686,11 +686,11 @@ public class SchedulerJobServiceImplTest {
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), false, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)
)));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
schedulerJobService.startExploratoryByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO).getExploratorySchedulerDataWithStatus(STOPPED);
verify(exploratoryService).start(refEq(getUserInfo()), eq(EXPLORATORY_NAME), eq(PROJECT));
verifyNoMoreInteractions(securityService, schedulerJobDAO, exploratoryService);
@@ -709,14 +709,14 @@ public class SchedulerJobServiceImplTest {
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), true, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)
)));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
when(computationalDAO.findComputationalResourcesWithStatus(anyString(), anyString(),
any(UserInstanceStatus.class))).thenReturn(singletonList(getComputationalResource(
DataEngineType.SPARK_STANDALONE, true)));
schedulerJobService.startExploratoryByScheduler();
- verify(securityService, times(2)).getServiceAccountInfo(USER);
+ verify(securityService, times(2)).getServiceAccountInfo();
verify(schedulerJobDAO).getExploratorySchedulerDataWithStatus(STOPPED);
verify(exploratoryService).start(refEq(getUserInfo()), eq(EXPLORATORY_NAME), eq(PROJECT));
verify(computationalDAO).findComputationalResourcesWithStatus(USER, EXPLORATORY_NAME, STOPPED);
@@ -736,14 +736,14 @@ public class SchedulerJobServiceImplTest {
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), true, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)
)));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
when(computationalDAO.findComputationalResourcesWithStatus(anyString(), anyString(),
any(UserInstanceStatus.class))).thenReturn(singletonList(getComputationalResource(
DataEngineType.CLOUD_SERVICE, true)));
schedulerJobService.startExploratoryByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO).getExploratorySchedulerDataWithStatus(STOPPED);
verify(exploratoryService).start(refEq(getUserInfo()), eq(EXPLORATORY_NAME), eq(PROJECT));
verify(computationalDAO).findComputationalResourcesWithStatus(USER, EXPLORATORY_NAME, STOPPED);
@@ -761,14 +761,14 @@ public class SchedulerJobServiceImplTest {
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)), true, USER,
LocalTime.now().truncatedTo(ChronoUnit.MINUTES)
)));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
when(computationalDAO.findComputationalResourcesWithStatus(anyString(), anyString(),
any(UserInstanceStatus.class))).thenReturn(singletonList(getComputationalResource(
DataEngineType.SPARK_STANDALONE, false)));
schedulerJobService.startExploratoryByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO).getExploratorySchedulerDataWithStatus(STOPPED);
verify(exploratoryService).start(refEq(getUserInfo()), eq(EXPLORATORY_NAME), eq(PROJECT));
verify(computationalDAO).findComputationalResourcesWithStatus(USER, EXPLORATORY_NAME, STOPPED);
@@ -855,11 +855,11 @@ public class SchedulerJobServiceImplTest {
);
when(schedulerJobDAO.getComputationalSchedulerDataWithOneOfStatus(any(UserInstanceStatus.class),
anyVararg())).thenReturn(singletonList(schedulerJobData));
- when(securityService.getServiceAccountInfo(anyString())).thenReturn(getUserInfo());
+ when(securityService.getServiceAccountInfo()).thenReturn(getUserInfo());
schedulerJobService.terminateComputationalByScheduler();
- verify(securityService).getServiceAccountInfo(USER);
+ verify(securityService).getServiceAccountInfo();
verify(schedulerJobDAO)
.getComputationalSchedulerDataWithOneOfStatus(RUNNING, STOPPED, RUNNING);
verify(computationalService).terminateComputational(refEq(getUserInfo()), eq(EXPLORATORY_NAME),
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@dlab.apache.org
For additional commands, e-mail: commits-help@dlab.apache.org