|
|
|
@ -32,11 +32,15 @@ import org.apache.dolphinscheduler.e2e.pages.project.workflow.task.ShellTaskForm
|
|
|
|
|
import org.apache.dolphinscheduler.e2e.pages.project.workflow.task.SubWorkflowTaskForm; |
|
|
|
|
import org.apache.dolphinscheduler.e2e.pages.security.SecurityPage; |
|
|
|
|
import org.apache.dolphinscheduler.e2e.pages.security.TenantPage; |
|
|
|
|
import org.apache.dolphinscheduler.e2e.pages.security.UserPage; |
|
|
|
|
import org.junit.jupiter.api.AfterAll; |
|
|
|
|
import org.junit.jupiter.api.BeforeAll; |
|
|
|
|
import org.junit.jupiter.api.Order; |
|
|
|
|
import org.junit.jupiter.api.Test; |
|
|
|
|
import org.openqa.selenium.By; |
|
|
|
|
import org.openqa.selenium.remote.RemoteWebDriver; |
|
|
|
|
import org.openqa.selenium.support.ui.ExpectedConditions; |
|
|
|
|
import org.openqa.selenium.support.ui.WebDriverWait; |
|
|
|
|
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat; |
|
|
|
|
import static org.awaitility.Awaitility.await; |
|
|
|
@ -44,46 +48,63 @@ import static org.awaitility.Awaitility.await;
|
|
|
|
|
@DolphinScheduler(composeFiles = "docker/basic/docker-compose.yaml") |
|
|
|
|
class WorkflowE2ETest { |
|
|
|
|
private static final String project = "test-workflow-1"; |
|
|
|
|
|
|
|
|
|
private static final String user = "admin"; |
|
|
|
|
|
|
|
|
|
private static final String password = "dolphinscheduler123"; |
|
|
|
|
|
|
|
|
|
private static final String email = "admin@gmail.com"; |
|
|
|
|
|
|
|
|
|
private static final String phone = "15800000000"; |
|
|
|
|
|
|
|
|
|
private static final String tenant = System.getProperty("user.name"); |
|
|
|
|
|
|
|
|
|
private static RemoteWebDriver browser; |
|
|
|
|
|
|
|
|
|
@BeforeAll |
|
|
|
|
public static void setup() { |
|
|
|
|
new LoginPage(browser) |
|
|
|
|
.login("admin", "dolphinscheduler123") |
|
|
|
|
.goToNav(SecurityPage.class) |
|
|
|
|
.goToTab(TenantPage.class) |
|
|
|
|
.create(tenant) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.create(project) |
|
|
|
|
UserPage userPage = new LoginPage(browser) |
|
|
|
|
.login("admin", "dolphinscheduler123") |
|
|
|
|
.goToNav(SecurityPage.class) |
|
|
|
|
.goToTab(TenantPage.class) |
|
|
|
|
.create(tenant) |
|
|
|
|
.goToNav(SecurityPage.class) |
|
|
|
|
.goToTab(UserPage.class); |
|
|
|
|
|
|
|
|
|
new WebDriverWait(userPage.driver(), 20).until(ExpectedConditions.visibilityOfElementLocated( |
|
|
|
|
new By.ByClassName("name"))); |
|
|
|
|
|
|
|
|
|
userPage.update(user, user, password, email, phone, tenant) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.create(project) |
|
|
|
|
; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@AfterAll |
|
|
|
|
public static void cleanup() { |
|
|
|
|
new NavBarPage(browser) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.goTo(project) |
|
|
|
|
.goToTab(WorkflowDefinitionTab.class) |
|
|
|
|
.cancelPublishAll() |
|
|
|
|
.deleteAll() |
|
|
|
|
; |
|
|
|
|
new NavBarPage(browser) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.delete(project) |
|
|
|
|
.goToNav(SecurityPage.class) |
|
|
|
|
.goToTab(TenantPage.class) |
|
|
|
|
.delete(tenant) |
|
|
|
|
; |
|
|
|
|
} |
|
|
|
|
// @AfterAll
|
|
|
|
|
// public static void cleanup() {
|
|
|
|
|
// new NavBarPage(browser)
|
|
|
|
|
// .goToNav(ProjectPage.class)
|
|
|
|
|
// .goTo(project)
|
|
|
|
|
// .goToTab(WorkflowDefinitionTab.class)
|
|
|
|
|
// .cancelPublishAll()
|
|
|
|
|
// .deleteAll()
|
|
|
|
|
// ;
|
|
|
|
|
//
|
|
|
|
|
// new NavBarPage(browser)
|
|
|
|
|
// .goToNav(ProjectPage.class)
|
|
|
|
|
// .delete(project)
|
|
|
|
|
// .goToNav(SecurityPage.class)
|
|
|
|
|
// .goToTab(TenantPage.class)
|
|
|
|
|
// .delete(tenant)
|
|
|
|
|
// ;
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
@Test |
|
|
|
|
@Order(1) |
|
|
|
|
void testCreateWorkflow() { |
|
|
|
|
final String workflow = "test-workflow-1"; |
|
|
|
|
|
|
|
|
|
final WorkflowDefinitionTab workflowDefinitionPage = |
|
|
|
|
WorkflowDefinitionTab workflowDefinitionPage = |
|
|
|
|
new ProjectPage(browser) |
|
|
|
|
.goTo(project) |
|
|
|
|
.goToTab(WorkflowDefinitionTab.class); |
|
|
|
@ -104,43 +125,47 @@ class WorkflowE2ETest {
|
|
|
|
|
.submit() |
|
|
|
|
; |
|
|
|
|
|
|
|
|
|
await().untilAsserted(() -> assertThat( |
|
|
|
|
workflowDefinitionPage.workflowList() |
|
|
|
|
).anyMatch(it -> it.getText().contains(workflow))); |
|
|
|
|
await().untilAsserted(() -> assertThat(workflowDefinitionPage.workflowList()) |
|
|
|
|
.as("Workflow list should contain newly-created workflow") |
|
|
|
|
.anyMatch( |
|
|
|
|
it -> it.getText().contains(workflow) |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
workflowDefinitionPage.publish(workflow); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Test |
|
|
|
|
@Order(10) |
|
|
|
|
void testCreateSubWorkflow() { |
|
|
|
|
final String workflow = "test-sub-workflow-1"; |
|
|
|
|
|
|
|
|
|
final WorkflowDefinitionTab workflowDefinitionPage = |
|
|
|
|
new ProjectPage(browser) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.goTo(project) |
|
|
|
|
.goToTab(WorkflowDefinitionTab.class); |
|
|
|
|
|
|
|
|
|
workflowDefinitionPage |
|
|
|
|
.createWorkflow() |
|
|
|
|
|
|
|
|
|
.<SubWorkflowTaskForm> addTask(TaskType.SUB_PROCESS) |
|
|
|
|
.submit() |
|
|
|
|
|
|
|
|
|
.submit() |
|
|
|
|
.name(workflow) |
|
|
|
|
.tenant(tenant) |
|
|
|
|
.addGlobalParam("global_param", "hello world") |
|
|
|
|
.submit() |
|
|
|
|
; |
|
|
|
|
|
|
|
|
|
await().untilAsserted(() -> assertThat( |
|
|
|
|
workflowDefinitionPage.workflowList() |
|
|
|
|
).anyMatch(it -> it.getText().contains(workflow))); |
|
|
|
|
|
|
|
|
|
workflowDefinitionPage.publish(workflow); |
|
|
|
|
} |
|
|
|
|
// @Test
|
|
|
|
|
// @Order(10)
|
|
|
|
|
// void testCreateSubWorkflow() {
|
|
|
|
|
// final String workflow = "test-sub-workflow-1";
|
|
|
|
|
//
|
|
|
|
|
// WorkflowDefinitionTab workflowDefinitionPage =
|
|
|
|
|
// new ProjectPage(browser)
|
|
|
|
|
// .goToNav(ProjectPage.class)
|
|
|
|
|
// .goTo(project)
|
|
|
|
|
// .goToTab(WorkflowDefinitionTab.class);
|
|
|
|
|
//
|
|
|
|
|
// workflowDefinitionPage
|
|
|
|
|
// .createWorkflow()
|
|
|
|
|
//
|
|
|
|
|
// .<SubWorkflowTaskForm> addTask(TaskType.SUB_PROCESS)
|
|
|
|
|
// .childNode("test-workflow-1")
|
|
|
|
|
// .name("test-sub-1")
|
|
|
|
|
// .submit()
|
|
|
|
|
//
|
|
|
|
|
// .submit()
|
|
|
|
|
// .name(workflow)
|
|
|
|
|
// .tenant(tenant)
|
|
|
|
|
// .addGlobalParam("global_param", "hello world")
|
|
|
|
|
// .submit()
|
|
|
|
|
// ;
|
|
|
|
|
//
|
|
|
|
|
// await().untilAsserted(() -> assertThat(
|
|
|
|
|
// workflowDefinitionPage.workflowList()
|
|
|
|
|
// ).anyMatch(it -> it.getText().contains(workflow)));
|
|
|
|
|
//
|
|
|
|
|
// workflowDefinitionPage.publish(workflow);
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
@Test |
|
|
|
|
@Order(30) |
|
|
|
@ -148,27 +173,27 @@ class WorkflowE2ETest {
|
|
|
|
|
final String workflow = "test-workflow-1"; |
|
|
|
|
|
|
|
|
|
final ProjectDetailPage projectPage = |
|
|
|
|
new ProjectPage(browser) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.goTo(project); |
|
|
|
|
new ProjectPage(browser) |
|
|
|
|
.goToNav(ProjectPage.class) |
|
|
|
|
.goTo(project); |
|
|
|
|
|
|
|
|
|
projectPage |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.deleteAll(); |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.deleteAll(); |
|
|
|
|
|
|
|
|
|
projectPage |
|
|
|
|
.goToTab(WorkflowDefinitionTab.class) |
|
|
|
|
.run(workflow) |
|
|
|
|
.submit(); |
|
|
|
|
.goToTab(WorkflowDefinitionTab.class) |
|
|
|
|
.run(workflow) |
|
|
|
|
.submit(); |
|
|
|
|
|
|
|
|
|
await().untilAsserted(() -> { |
|
|
|
|
browser.navigate().refresh(); |
|
|
|
|
|
|
|
|
|
final Row row = projectPage |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.instances() |
|
|
|
|
.iterator() |
|
|
|
|
.next(); |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.instances() |
|
|
|
|
.iterator() |
|
|
|
|
.next(); |
|
|
|
|
|
|
|
|
|
assertThat(row.isSuccess()).isTrue(); |
|
|
|
|
assertThat(row.executionTime()).isEqualTo(1); |
|
|
|
@ -176,22 +201,22 @@ class WorkflowE2ETest {
|
|
|
|
|
|
|
|
|
|
// Test rerun
|
|
|
|
|
projectPage |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.instances() |
|
|
|
|
.stream() |
|
|
|
|
.filter(it -> it.rerunButton().isDisplayed()) |
|
|
|
|
.iterator() |
|
|
|
|
.next() |
|
|
|
|
.rerun(); |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.instances() |
|
|
|
|
.stream() |
|
|
|
|
.filter(it -> it.rerunButton().isDisplayed()) |
|
|
|
|
.iterator() |
|
|
|
|
.next() |
|
|
|
|
.rerun(); |
|
|
|
|
|
|
|
|
|
await().untilAsserted(() -> { |
|
|
|
|
browser.navigate().refresh(); |
|
|
|
|
|
|
|
|
|
final Row row = projectPage |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.instances() |
|
|
|
|
.iterator() |
|
|
|
|
.next(); |
|
|
|
|
.goToTab(WorkflowInstanceTab.class) |
|
|
|
|
.instances() |
|
|
|
|
.iterator() |
|
|
|
|
.next(); |
|
|
|
|
|
|
|
|
|
assertThat(row.isSuccess()).isTrue(); |
|
|
|
|
assertThat(row.executionTime()).isEqualTo(2); |
|
|
|
|