1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: AGPL-3.0
5 import { ContainerState } from "models/container";
7 describe("Process tests", function () {
12 // Only set up common users once. These aren't set up as aliases because
13 // aliases are cleaned up after every test. Also it doesn't make sense
14 // to set the same users on beforeEach() over and over again, so we
15 // separate a little from Cypress' 'Best Practices' here.
16 cy.getUser("admin", "Admin", "User", true, true)
19 adminUser = this.adminUser;
21 cy.getUser("user", "Active", "User", false, true)
24 activeUser = this.activeUser;
28 function setupDockerImage(image_name) {
29 // Create a collection that will be used as a docker image for the tests.
30 cy.createCollection(adminUser.token, {
33 ". d21353cfe035e3e384563ee55eadbb2f+67108864 5c77a43e329b9838cbec18ff42790e57+55605760 0:122714624:sha256:d8309758b8fe2c81034ffc8a10c36460b77db7bc5e7b448c4e5b684f9d95a678.tar\n",
36 .then(function (dockerImage) {
37 // Give read permissions to the active user on the docker image.
38 cy.createLink(adminUser.token, {
39 link_class: "permission",
41 tail_uuid: activeUser.user.uuid,
42 head_uuid: dockerImage.uuid,
44 .as("dockerImagePermission")
46 // Set-up docker image collection tags
47 cy.createLink(activeUser.token, {
48 link_class: "docker_image_repo+tag",
50 head_uuid: dockerImage.uuid,
51 }).as("dockerImageRepoTag");
52 cy.createLink(activeUser.token, {
53 link_class: "docker_image_hash",
54 name: "sha256:d8309758b8fe2c81034ffc8a10c36460b77db7bc5e7b448c4e5b684f9d95a678",
55 head_uuid: dockerImage.uuid,
56 }).as("dockerImageHash");
59 return cy.getAll("@dockerImage", "@dockerImageRepoTag", "@dockerImageHash", "@dockerImagePermission").then(function ([dockerImage]) {
64 function createContainerRequest(user, name, docker_image, command, reuse = false, state = "Uncommitted") {
65 return setupDockerImage(docker_image).then(function (dockerImage) {
66 return cy.createContainerRequest(user.token, {
69 container_image: dockerImage.portable_data_hash, // for some reason, docker_image doesn't work here
70 output_path: "stdout.txt",
72 runtime_constraints: {
88 describe('Multiselect Toolbar', () => {
89 it('shows the appropriate buttons in the toolbar', () => {
91 const msButtonTooltips = [
97 'Copy and re-run process',
103 createContainerRequest(
105 `test_container_request ${Math.floor(Math.random() * 999999)}`,
107 ["echo", "hello world"],
110 ).then(function (containerRequest) {
111 cy.loginAs(activeUser);
112 cy.goToPath(`/processes/${containerRequest.uuid}`);
113 cy.get("[data-cy=process-details]").should("contain", containerRequest.name);
114 cy.get("[data-cy=process-details-attributes-modifiedby-user]").contains(`Active User (${activeUser.user.uuid})`);
115 cy.get("[data-cy=process-details-attributes-runtime-user]").should("not.exist");
116 cy.get("[data-cy=side-panel-tree]").contains("Home Projects").click();
118 cy.get('[data-cy=mpv-tabs]').contains("Workflow Runs").click();
119 cy.get('[data-cy=data-table-row]').contains(containerRequest.name).should('exist').parents('[data-cy=data-table-row]').click()
121 cy.get('[data-cy=multiselect-button]').should('have.length', msButtonTooltips.length)
122 for (let i = 0; i < msButtonTooltips.length; i++) {
123 cy.get('[data-cy=multiselect-button]').eq(i).trigger('mouseover');
124 cy.get('body').contains(msButtonTooltips[i]).should('exist')
125 cy.get('[data-cy=multiselect-button]').eq(i).trigger('mouseout');
131 describe("Details panel", function () {
132 it("shows process details", function () {
133 createContainerRequest(
135 `test_container_request ${Math.floor(Math.random() * 999999)}`,
137 ["echo", "hello world"],
140 ).then(function (containerRequest) {
141 cy.loginAs(activeUser);
142 cy.goToPath(`/processes/${containerRequest.uuid}`);
143 cy.get("[data-cy=process-details]").should("contain", containerRequest.name);
144 cy.get("[data-cy=process-details-attributes-modifiedby-user]").contains(`Active User (${activeUser.user.uuid})`);
145 cy.get("[data-cy=process-details-attributes-runtime-user]").should("not.exist");
148 // Fake submitted by another user
149 cy.intercept({ method: "GET", url: "**/arvados/v1/container_requests/*" }, req => {
150 req.on('response', res => {
151 res.body.modified_by_user_uuid = "zzzzz-tpzed-000000000000000";
155 createContainerRequest(
157 `test_container_request ${Math.floor(Math.random() * 999999)}`,
159 ["echo", "hello world"],
162 ).then(function (containerRequest) {
163 cy.loginAs(activeUser);
164 cy.goToPath(`/processes/${containerRequest.uuid}`);
165 cy.get("[data-cy=process-details]").should("contain", containerRequest.name);
166 cy.get("[data-cy=process-details-attributes-modifiedby-user]").contains(`zzzzz-tpzed-000000000000000`);
167 cy.get("[data-cy=process-details-attributes-runtime-user]").contains(`Active User (${activeUser.user.uuid})`);
171 it("should show runtime status indicators", function () {
172 // Setup running container with runtime_status error & warning messages
173 createContainerRequest(activeUser, "test_container_request", "arvados/jobs", ["echo", "hello world"], false, "Committed")
174 .as("containerRequest")
175 .then(function (containerRequest) {
176 expect(containerRequest.state).to.equal("Committed");
177 expect(containerRequest.container_uuid).not.to.be.equal("");
179 cy.getContainer(activeUser.token, containerRequest.container_uuid).then(function (queuedContainer) {
180 expect(queuedContainer.state).to.be.equal("Queued");
182 cy.updateContainer(adminUser.token, containerRequest.container_uuid, {
184 }).then(function (lockedContainer) {
185 expect(lockedContainer.state).to.be.equal("Locked");
187 cy.updateContainer(adminUser.token, lockedContainer.uuid, {
190 error: "Something went wrong",
191 errorDetail: "Process exited with status 1",
192 warning: "Free disk space is low",
195 .as("runningContainer")
196 .then(function (runningContainer) {
197 expect(runningContainer.state).to.be.equal("Running");
198 expect(runningContainer.runtime_status).to.be.deep.equal({
199 error: "Something went wrong",
200 errorDetail: "Process exited with status 1",
201 warning: "Free disk space is low",
206 // Test that the UI shows the error and warning messages
207 cy.getAll("@containerRequest", "@runningContainer").then(function ([containerRequest]) {
208 cy.loginAs(activeUser);
209 cy.goToPath(`/processes/${containerRequest.uuid}`);
210 cy.get("[data-cy=process-runtime-status-error]")
211 .should("contain", "Something went wrong")
212 .and("contain", "Process exited with status 1");
213 cy.get("[data-cy=process-runtime-status-warning]")
214 .should("contain", "Free disk space is low")
215 .and("contain", "No additional warning details available");
218 // Force container_count for testing
219 let containerCount = 2;
220 cy.intercept({ method: "GET", url: "**/arvados/v1/container_requests/*" }, req => {
221 req.on('response', res => {
222 res.body.container_count = containerCount;
226 cy.getAll("@containerRequest").then(function ([containerRequest]) {
227 cy.goToPath(`/processes/${containerRequest.uuid}`);
228 cy.get("[data-cy=process-runtime-status-retry-warning]", { timeout: 7000 }).should("contain", "Process retried 1 time");
231 cy.getAll("@containerRequest").then(function ([containerRequest]) {
233 cy.goToPath(`/processes/${containerRequest.uuid}`);
234 cy.get("[data-cy=process-runtime-status-retry-warning]", { timeout: 7000 }).should("contain", "Process retried 2 times");
238 it("allows copying processes", function () {
239 const crName = "first_container_request";
240 const copiedCrName = "copied_container_request";
241 createContainerRequest(activeUser, crName, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (containerRequest) {
242 cy.loginAs(activeUser);
243 cy.goToPath(`/processes/${containerRequest.uuid}`);
244 cy.get("[data-cy=process-details]").should("contain", crName);
246 cy.get("[data-cy=process-details]").find('button[title="More options"]').click();
247 cy.get("ul[data-cy=context-menu]").contains("Copy and re-run process").click();
250 cy.get("[data-cy=form-dialog]").within(() => {
251 cy.get("input[name=name]").clear().type(copiedCrName);
252 cy.get("[data-cy=projects-tree-home-tree-picker]").click();
253 cy.get("[data-cy=form-submit-btn]").click();
256 cy.get("[data-cy=process-details]").should("contain", copiedCrName);
257 cy.get("[data-cy=process-details]").find("button").contains("Run");
260 const getFakeContainer = fakeContainerUuid => ({
261 href: `/containers/${fakeContainerUuid}`,
262 kind: "arvados#container",
263 etag: "ecfosljpnxfari9a8m7e4yv06",
264 uuid: fakeContainerUuid,
265 owner_uuid: "zzzzz-tpzed-000000000000000",
266 created_at: "2023-02-13T15:55:47.308915000Z",
267 modified_by_client_uuid: "zzzzz-ozdt8-q6dzdi1lcc03155",
268 modified_by_user_uuid: "zzzzz-tpzed-000000000000000",
269 modified_at: "2023-02-15T19:12:45.987086000Z",
271 "arvados-cwl-runner",
274 "--project-uuid=zzzzz-j7d0g-yr18k784zplfeza",
275 "/var/lib/cwl/workflow.json#main",
276 "/var/lib/cwl/cwl.input.json",
278 container_image: "4ad7d11381df349e464694762db14e04+303",
279 cwd: "/var/spool/cwl",
283 locked_by_uuid: null,
286 output_path: "/var/spool/cwl",
288 runtime_constraints: {
293 hardware_capability: "",
295 keep_cache_disk: 2147483648,
303 scheduling_parameters: {
308 runtime_user_uuid: "zzzzz-tpzed-vllbpebicy84rd5",
309 runtime_auth_scopes: ["all"],
311 gateway_address: null,
312 interactive_session_started: false,
313 output_storage_classes: ["default"],
314 output_properties: {},
316 subrequests_cost: 0.0,
319 it("shows cancel button when appropriate", function () {
320 // Ignore collection requests
322 { method: "GET", url: `**/arvados/v1/collections/*` },
329 // Uncommitted container
330 const crUncommitted = `Test process ${Math.floor(Math.random() * 999999)}`;
331 createContainerRequest(activeUser, crUncommitted, "arvados/jobs", ["echo", "hello world"], false, "Uncommitted").then(function (
334 cy.loginAs(activeUser);
335 // Navigate to process and verify run / cancel button
336 cy.goToPath(`/processes/${containerRequest.uuid}`);
338 cy.get("[data-cy=process-details]").should("contain", crUncommitted);
339 cy.get("[data-cy=process-run-button]").should("exist");
340 cy.get("[data-cy=process-cancel-button]").should("not.exist");
344 const crQueued = `Test process ${Math.floor(Math.random() * 999999)}`;
345 const fakeCrUuid = "zzzzz-dz642-000000000000001";
346 createContainerRequest(activeUser, crQueued, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (
349 // Fake container uuid
350 cy.intercept({ method: "GET", url: `**/arvados/v1/container_requests/${containerRequest.uuid}` }, req => {
351 req.on('response', res => {
352 res.body.output_uuid = fakeCrUuid;
353 res.body.priority = 500;
354 res.body.state = "Committed";
359 const container = getFakeContainer(fakeCrUuid);
361 { method: "GET", url: `**/arvados/v1/container/${fakeCrUuid}` },
364 body: { ...container, state: "Queued", priority: 500 },
368 // Navigate to process and verify cancel button
369 cy.goToPath(`/processes/${containerRequest.uuid}`);
371 cy.get("[data-cy=process-details]").should("contain", crQueued);
372 cy.get("[data-cy=process-cancel-button]").contains("Cancel");
376 const crLocked = `Test process ${Math.floor(Math.random() * 999999)}`;
377 const fakeCrLockedUuid = "zzzzz-dz642-000000000000002";
378 createContainerRequest(activeUser, crLocked, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (
381 // Fake container uuid
382 cy.intercept({ method: "GET", url: `**/arvados/v1/container_requests/${containerRequest.uuid}` }, req => {
383 req.on('response', res => {
384 res.body.output_uuid = fakeCrLockedUuid;
385 res.body.priority = 500;
386 res.body.state = "Committed";
391 const container = getFakeContainer(fakeCrLockedUuid);
393 { method: "GET", url: `**/arvados/v1/container/${fakeCrLockedUuid}` },
396 body: { ...container, state: "Locked", priority: 500 },
400 // Navigate to process and verify cancel button
401 cy.goToPath(`/processes/${containerRequest.uuid}`);
403 cy.get("[data-cy=process-details]").should("contain", crLocked);
404 cy.get("[data-cy=process-cancel-button]").contains("Cancel");
408 const crOnHold = `Test process ${Math.floor(Math.random() * 999999)}`;
409 const fakeCrOnHoldUuid = "zzzzz-dz642-000000000000003";
410 createContainerRequest(activeUser, crOnHold, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (
413 // Fake container uuid
414 cy.intercept({ method: "GET", url: `**/arvados/v1/container_requests/${containerRequest.uuid}` }, req => {
415 req.on('response', res => {
416 res.body.output_uuid = fakeCrOnHoldUuid;
417 res.body.priority = 0;
418 res.body.state = "Committed";
423 const container = getFakeContainer(fakeCrOnHoldUuid);
425 { method: "GET", url: `**/arvados/v1/container/${fakeCrOnHoldUuid}` },
428 body: { ...container, state: "Queued", priority: 0 },
432 // Navigate to process and verify cancel button
433 cy.goToPath(`/processes/${containerRequest.uuid}`);
435 cy.get("[data-cy=process-details]").should("contain", crOnHold);
436 cy.get("[data-cy=process-run-button]").should("exist");
437 cy.get("[data-cy=process-cancel-button]").should("not.exist");
442 describe("Logs panel", function () {
443 it("shows live process logs", function () {
444 cy.intercept({ method: "GET", url: "**/arvados/v1/containers/*" }, req => {
445 req.on('response', res => {
446 res.body.state = ContainerState.RUNNING;
450 const crName = "test_container_request";
451 createContainerRequest(activeUser, crName, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (containerRequest) {
452 // Create empty log file before loading process page
453 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", [""]);
455 cy.loginAs(activeUser);
456 cy.goToPath(`/processes/${containerRequest.uuid}`);
457 cy.get("[data-cy=process-details]").should("contain", crName);
458 cy.get("[data-cy=process-logs]").should("contain", "No logs yet").and("not.contain", "hello world");
461 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", ["2023-07-18T20:14:48.128642814Z hello world"]).then(() => {
462 cy.get("[data-cy=process-logs]", { timeout: 7000 }).should("not.contain", "No logs yet").and("contain", "hello world");
465 // Append new log line to different file
466 cy.appendLog(adminUser.token, containerRequest.uuid, "stderr.txt", ["2023-07-18T20:14:49.128642814Z hello new line"]).then(() => {
467 cy.get("[data-cy=process-logs]", { timeout: 7000 }).should("not.contain", "No logs yet").and("contain", "hello new line");
472 it("filters process logs by event type", function () {
473 const nodeInfoLogs = [
475 "Linux compute-99cb150b26149780de44b929577e1aed-19rgca8vobuvc4p 5.4.0-1059-azure #62~18.04.1-Ubuntu SMP Tue Sep 14 17:53:18 UTC 2021 x86_64 x86_64 x86_64 GNU/Linux",
478 "vendor_id : GenuineIntel",
481 "model name : Intel(R) Xeon(R) CPU E5-2673 v4 @ 2.30GHz",
483 const crunchRunLogs = [
484 "2022-03-22T13:56:22.542417997Z using local keepstore process (pid 3733) at http://localhost:46837, writing logs to keepstore.txt in log collection",
485 "2022-03-22T13:56:26.237571754Z crunch-run 2.4.0~dev20220321141729 (go1.17.1) started",
486 "2022-03-22T13:56:26.244704134Z crunch-run process has uid=0(root) gid=0(root) groups=0(root)",
487 "2022-03-22T13:56:26.244862836Z Executing container 'zzzzz-dz642-1wokwvcct9s9du3' using docker runtime",
488 "2022-03-22T13:56:26.245037738Z Executing on host 'compute-99cb150b26149780de44b929577e1aed-19rgca8vobuvc4p'",
491 "2022-03-22T13:56:22.542417987Z Lorem ipsum dolor sit amet, consectetur adipiscing elit. Donec dui nisi, hendrerit porta sapien a, pretium dignissim purus.",
492 "2022-03-22T13:56:22.542417997Z Integer viverra, mauris finibus aliquet ultricies, dui mauris cursus justo, ut venenatis nibh ex eget neque.",
493 "2022-03-22T13:56:22.542418007Z In hac habitasse platea dictumst.",
494 "2022-03-22T13:56:22.542418027Z Fusce fringilla turpis id accumsan faucibus. Donec congue congue ex non posuere. In semper mi quis tristique rhoncus.",
495 "2022-03-22T13:56:22.542418037Z Interdum et malesuada fames ac ante ipsum primis in faucibus.",
496 "2022-03-22T13:56:22.542418047Z Quisque fermentum tortor ex, ut suscipit velit feugiat faucibus.",
497 "2022-03-22T13:56:22.542418057Z Donec vitae porta risus, at luctus nulla. Mauris gravida iaculis ipsum, id sagittis tortor egestas ac.",
498 "2022-03-22T13:56:22.542418067Z Maecenas condimentum volutpat nulla. Integer lacinia maximus risus eu posuere.",
499 "2022-03-22T13:56:22.542418077Z Donec vitae leo id augue gravida bibendum.",
500 "2022-03-22T13:56:22.542418087Z Nam libero libero, pretium ac faucibus elementum, mattis nec ex.",
501 "2022-03-22T13:56:22.542418097Z Nullam id laoreet nibh. Vivamus tellus metus, pretium quis justo ut, bibendum varius metus. Pellentesque vitae accumsan lorem, quis tincidunt augue.",
502 "2022-03-22T13:56:22.542418107Z Aliquam viverra nisi nulla, et efficitur dolor mattis in.",
503 "2022-03-22T13:56:22.542418117Z Sed at enim sit amet nulla tincidunt mattis. Aenean eget aliquet ex, non ultrices ex. Nulla ex tortor, vestibulum aliquam tempor ac, aliquam vel est.",
504 "2022-03-22T13:56:22.542418127Z Fusce auctor faucibus libero id venenatis. Etiam sodales, odio eu cursus efficitur, quam sem blandit ex, quis porttitor enim dui quis lectus. In id tincidunt felis.",
505 "2022-03-22T13:56:22.542418137Z Phasellus non ex quis arcu tempus faucibus molestie in sapien.",
506 "2022-03-22T13:56:22.542418147Z Duis tristique semper dolor, vitae pulvinar risus.",
507 "2022-03-22T13:56:22.542418157Z Aliquam tortor elit, luctus nec tortor eget, porta tristique nulla.",
508 "2022-03-22T13:56:22.542418167Z Nulla eget mollis ipsum.",
511 createContainerRequest(activeUser, "test_container_request", "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (
514 cy.appendLog(adminUser.token, containerRequest.uuid, "node-info.txt", nodeInfoLogs).as("nodeInfoLogs");
515 cy.appendLog(adminUser.token, containerRequest.uuid, "crunch-run.txt", crunchRunLogs).as("crunchRunLogs");
516 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", stdoutLogs).as("stdoutLogs");
518 cy.getAll("@stdoutLogs", "@nodeInfoLogs", "@crunchRunLogs").then(function () {
519 cy.loginAs(activeUser);
520 cy.goToPath(`/processes/${containerRequest.uuid}`);
521 // Should show main logs by default
522 cy.get("[data-cy=process-logs-filter]", { timeout: 7000 }).should("contain", "Main logs");
523 cy.get("[data-cy=process-logs]")
524 .should("contain", stdoutLogs[Math.floor(Math.random() * stdoutLogs.length)])
525 .and("not.contain", nodeInfoLogs[Math.floor(Math.random() * nodeInfoLogs.length)])
526 .and("contain", crunchRunLogs[Math.floor(Math.random() * crunchRunLogs.length)]);
528 cy.get("[data-cy=process-logs-filter]").click();
529 cy.get("body").contains("li", "All logs").click();
530 cy.get("[data-cy=process-logs]")
531 .should("contain", stdoutLogs[Math.floor(Math.random() * stdoutLogs.length)])
532 .and("contain", nodeInfoLogs[Math.floor(Math.random() * nodeInfoLogs.length)])
533 .and("contain", crunchRunLogs[Math.floor(Math.random() * crunchRunLogs.length)]);
534 // Select 'node-info' logs
535 cy.get("[data-cy=process-logs-filter]").click();
536 cy.get("body").contains("li", "node-info").click();
537 cy.get("[data-cy=process-logs]")
538 .should("not.contain", stdoutLogs[Math.floor(Math.random() * stdoutLogs.length)])
539 .and("contain", nodeInfoLogs[Math.floor(Math.random() * nodeInfoLogs.length)])
540 .and("not.contain", crunchRunLogs[Math.floor(Math.random() * crunchRunLogs.length)]);
541 // Select 'stdout' logs
542 cy.get("[data-cy=process-logs-filter]").click();
543 cy.get("body").contains("li", "stdout").click();
544 cy.get("[data-cy=process-logs]")
545 .should("contain", stdoutLogs[Math.floor(Math.random() * stdoutLogs.length)])
546 .and("not.contain", nodeInfoLogs[Math.floor(Math.random() * nodeInfoLogs.length)])
547 .and("not.contain", crunchRunLogs[Math.floor(Math.random() * crunchRunLogs.length)]);
552 it("sorts combined logs", function () {
553 const crName = "test_container_request";
554 createContainerRequest(activeUser, crName, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (containerRequest) {
555 cy.appendLog(adminUser.token, containerRequest.uuid, "node-info.txt", [
563 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", [
564 "2023-07-18T20:14:48.128642814Z first",
565 "2023-07-18T20:14:49.128642814Z third",
568 cy.appendLog(adminUser.token, containerRequest.uuid, "stderr.txt", ["2023-07-18T20:14:48.528642814Z second"]).as("stderr");
570 cy.loginAs(activeUser);
571 cy.goToPath(`/processes/${containerRequest.uuid}`);
572 cy.get("[data-cy=process-details]").should("contain", crName);
573 cy.get("[data-cy=process-logs]").should("contain", "No logs yet");
575 cy.getAll("@node-info", "@stdout", "@stderr").then(() => {
576 // Verify sorted main logs
577 cy.get("[data-cy=process-logs] span > p", { timeout: 7000 }).eq(0).should("contain", "2023-07-18T20:14:48.128642814Z first");
578 cy.get("[data-cy=process-logs] span > p").eq(1).should("contain", "2023-07-18T20:14:48.528642814Z second");
579 cy.get("[data-cy=process-logs] span > p").eq(2).should("contain", "2023-07-18T20:14:49.128642814Z third");
581 // Switch to All logs
582 cy.get("[data-cy=process-logs-filter]").click();
583 cy.get("body").contains("li", "All logs").click();
584 // Verify non-sorted lines were preserved
585 cy.get("[data-cy=process-logs] span > p").eq(0).should("contain", "3: nodeinfo 1");
586 cy.get("[data-cy=process-logs] span > p").eq(1).should("contain", "2: nodeinfo 2");
587 cy.get("[data-cy=process-logs] span > p").eq(2).should("contain", "1: nodeinfo 3");
588 cy.get("[data-cy=process-logs] span > p").eq(3).should("contain", "2: nodeinfo 4");
589 cy.get("[data-cy=process-logs] span > p").eq(4).should("contain", "3: nodeinfo 5");
590 // Verify sorted logs
591 cy.get("[data-cy=process-logs] span > p").eq(5).should("contain", "2023-07-18T20:14:48.128642814Z first");
592 cy.get("[data-cy=process-logs] span > p").eq(6).should("contain", "2023-07-18T20:14:48.528642814Z second");
593 cy.get("[data-cy=process-logs] span > p").eq(7).should("contain", "2023-07-18T20:14:49.128642814Z third");
598 it("preserves original ordering of lines within the same log type", function () {
599 const crName = "test_container_request";
600 createContainerRequest(activeUser, crName, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (containerRequest) {
601 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", [
603 "2023-07-18T20:14:46.000000000Z A out 1",
604 // Comes fourth in a contiguous block
605 "2023-07-18T20:14:48.128642814Z A out 2",
606 "2023-07-18T20:14:48.128642814Z X out 3",
607 "2023-07-18T20:14:48.128642814Z A out 4",
610 cy.appendLog(adminUser.token, containerRequest.uuid, "stderr.txt", [
612 "2023-07-18T20:14:47.000000000Z Z err 1",
613 // Comes third in a contiguous block
614 "2023-07-18T20:14:48.128642814Z B err 2",
615 "2023-07-18T20:14:48.128642814Z C err 3",
616 "2023-07-18T20:14:48.128642814Z Y err 4",
617 "2023-07-18T20:14:48.128642814Z Z err 5",
618 "2023-07-18T20:14:48.128642814Z A err 6",
621 cy.loginAs(activeUser);
622 cy.goToPath(`/processes/${containerRequest.uuid}`);
623 cy.get("[data-cy=process-details]").should("contain", crName);
624 cy.get("[data-cy=process-logs]").should("contain", "No logs yet");
626 cy.getAll("@stdout", "@stderr").then(() => {
627 // Switch to All logs
628 cy.get("[data-cy=process-logs-filter]").click();
629 cy.get("body").contains("li", "All logs").click();
630 // Verify sorted logs
631 cy.get("[data-cy=process-logs] span > p").eq(0).should("contain", "2023-07-18T20:14:46.000000000Z A out 1");
632 cy.get("[data-cy=process-logs] span > p").eq(1).should("contain", "2023-07-18T20:14:47.000000000Z Z err 1");
633 cy.get("[data-cy=process-logs] span > p").eq(2).should("contain", "2023-07-18T20:14:48.128642814Z B err 2");
634 cy.get("[data-cy=process-logs] span > p").eq(3).should("contain", "2023-07-18T20:14:48.128642814Z C err 3");
635 cy.get("[data-cy=process-logs] span > p").eq(4).should("contain", "2023-07-18T20:14:48.128642814Z Y err 4");
636 cy.get("[data-cy=process-logs] span > p").eq(5).should("contain", "2023-07-18T20:14:48.128642814Z Z err 5");
637 cy.get("[data-cy=process-logs] span > p").eq(6).should("contain", "2023-07-18T20:14:48.128642814Z A err 6");
638 cy.get("[data-cy=process-logs] span > p").eq(7).should("contain", "2023-07-18T20:14:48.128642814Z A out 2");
639 cy.get("[data-cy=process-logs] span > p").eq(8).should("contain", "2023-07-18T20:14:48.128642814Z X out 3");
640 cy.get("[data-cy=process-logs] span > p").eq(9).should("contain", "2023-07-18T20:14:48.128642814Z A out 4");
645 it("correctly generates sniplines", function () {
646 const SNIPLINE = `================ ✀ ================ ✀ ========= Some log(s) were skipped ========= ✀ ================ ✀ ================`;
647 const crName = "test_container_request";
648 createContainerRequest(activeUser, crName, "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (containerRequest) {
649 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", [
650 "X".repeat(63999) + "_" + "O".repeat(100) + "_" + "X".repeat(63999),
653 cy.loginAs(activeUser);
654 cy.goToPath(`/processes/${containerRequest.uuid}`);
655 cy.get("[data-cy=process-details]").should("contain", crName);
656 cy.get("[data-cy=process-logs]").should("contain", "No logs yet");
658 // Switch to stdout since lines are unsortable (no timestamp)
659 cy.get("[data-cy=process-logs-filter]").click();
660 cy.get("body").contains("li", "stdout").click();
662 cy.getAll("@stdout").then(() => {
663 // Verify first 64KB and snipline
664 cy.get("[data-cy=process-logs] span > p", { timeout: 7000 })
666 .should("contain", "X".repeat(63999) + "_\n" + SNIPLINE);
668 cy.get("[data-cy=process-logs] span > p")
670 .should("contain", "_" + "X".repeat(63999));
671 // Verify none of the Os got through
672 cy.get("[data-cy=process-logs] span > p").should("not.contain", "O");
677 it("correctly break long lines when no obvious line separation exists", function () {
678 function randomString(length) {
679 const chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
681 for (let i = 0; i < length; i++) {
682 res += chars.charAt(Math.floor(Math.random() * chars.length));
687 const logLinesQty = 10;
689 for (let i = 0; i < logLinesQty; i++) {
690 const length = Math.floor(Math.random() * 500) + 500;
691 logLines.push(randomString(length));
694 createContainerRequest(activeUser, "test_container_request", "arvados/jobs", ["echo", "hello world"], false, "Committed").then(function (
697 cy.appendLog(adminUser.token, containerRequest.uuid, "stdout.txt", logLines).as("stdoutLogs");
699 cy.getAll("@stdoutLogs").then(function () {
700 cy.loginAs(activeUser);
701 cy.goToPath(`/processes/${containerRequest.uuid}`);
702 // Select 'stdout' log filter
703 cy.get("[data-cy=process-logs-filter]").click();
704 cy.get("body").contains("li", "stdout").click();
705 cy.get("[data-cy=process-logs] span > p")
706 .should('have.length', logLinesQty)
708 expect($p.text().length).to.be.greaterThan(499);
710 // This looks like an ugly hack, but I was not able
711 // to get [client|scroll]Width attributes through
712 // the usual Cypress methods.
713 const parentClientWidth = $p[0].parentElement.clientWidth;
714 const parentScrollWidth = $p[0].parentElement.scrollWidth
715 // Scrollbar should not be visible
716 expect(parentClientWidth).to.be.eq(parentScrollWidth);
723 describe("I/O panel", function () {
727 id: "#main/input_file",
728 label: "Label Description",
733 basename: "input1.tar",
735 location: "keep:00000000000000000000000000000000+01/input1.tar",
738 basename: "input1-2.txt",
740 location: "keep:00000000000000000000000000000000+01/input1-2.txt",
743 basename: "input1-3.txt",
745 location: "keep:00000000000000000000000000000000+01/input1-3.txt",
748 basename: "input1-4.txt",
750 location: "keep:00000000000000000000000000000000+01/input1-4.txt",
758 id: "#main/input_dir",
759 doc: "Doc Description",
764 basename: "11111111111111111111111111111111+01",
766 location: "keep:11111111111111111111111111111111+01",
772 id: "#main/input_bool",
773 doc: ["Doc desc 1", "Doc desc 2"],
782 id: "#main/input_int",
791 id: "#main/input_long",
800 id: "#main/input_float",
809 id: "#main/input_double",
818 id: "#main/input_string",
822 input_string: "Hello World",
827 id: "#main/input_file_array",
836 basename: "input2.tar",
838 location: "keep:00000000000000000000000000000000+02/input2.tar",
841 basename: "input3.tar",
843 location: "keep:00000000000000000000000000000000+03/input3.tar",
846 basename: "input3-2.txt",
848 location: "keep:00000000000000000000000000000000+03/input3-2.txt",
853 $import: "import_path",
860 id: "#main/input_dir_array",
869 basename: "11111111111111111111111111111111+02",
871 location: "keep:11111111111111111111111111111111+02",
874 basename: "11111111111111111111111111111111+03",
876 location: "keep:11111111111111111111111111111111+03",
879 $import: "import_path",
886 id: "#main/input_int_array",
898 $import: "import_path",
905 id: "#main/input_long_array",
916 $import: "import_path",
923 id: "#main/input_float_array",
935 $import: "import_path",
942 id: "#main/input_double_array",
949 input_double_array: [
954 $import: "import_path",
961 id: "#main/input_string_array",
968 input_string_array: [
973 $import: "import_path",
980 id: "#main/input_bool_include",
984 input_bool_include: {
985 $include: "include_path",
991 id: "#main/input_int_include",
996 $include: "include_path",
1002 id: "#main/input_float_include",
1006 input_float_include: {
1007 $include: "include_path",
1013 id: "#main/input_string_include",
1017 input_string_include: {
1018 $include: "include_path",
1024 id: "#main/input_file_include",
1028 input_file_include: {
1029 $include: "include_path",
1035 id: "#main/input_directory_include",
1039 input_directory_include: {
1040 $include: "include_path",
1046 id: "#main/input_file_url",
1051 basename: "index.html",
1053 location: "http://example.com/index.html",
1059 const testOutputs = [
1062 id: "#main/output_file",
1063 label: "Label Description",
1068 basename: "cat.png",
1070 location: "cat.png",
1076 id: "#main/output_file_with_secondary",
1077 doc: "Doc Description",
1081 output_file_with_secondary: {
1082 basename: "main.dat",
1084 location: "main.dat",
1087 basename: "secondary.dat",
1089 location: "secondary.dat",
1092 basename: "secondary2.dat",
1094 location: "secondary2.dat",
1102 id: "#main/output_dir",
1103 doc: ["Doc desc 1", "Doc desc 2"],
1108 basename: "outdir1",
1110 location: "outdir1",
1116 id: "#main/output_bool",
1125 id: "#main/output_int",
1134 id: "#main/output_long",
1143 id: "#main/output_float",
1147 output_float: 100.5,
1152 id: "#main/output_double",
1156 output_double: 100.3,
1161 id: "#main/output_string",
1165 output_string: "Hello output",
1170 id: "#main/output_file_array",
1177 output_file_array: [
1179 basename: "output2.tar",
1181 location: "output2.tar",
1184 basename: "output3.tar",
1186 location: "output3.tar",
1193 id: "#main/output_dir_array",
1202 basename: "outdir2",
1204 location: "outdir2",
1207 basename: "outdir3",
1209 location: "outdir3",
1216 id: "#main/output_int_array",
1223 output_int_array: [10, 11, 12],
1228 id: "#main/output_long_array",
1235 output_long_array: [51, 52],
1240 id: "#main/output_float_array",
1247 output_float_array: [100.2, 100.4, 100.6],
1252 id: "#main/output_double_array",
1259 output_double_array: [100.1, 100.2, 100.3],
1264 id: "#main/output_string_array",
1271 output_string_array: ["Hello", "Output", "!"],
1276 const verifyIOParameter = (name, label, doc, val, collection, multipleRows) => {
1280 .within($mainRow => {
1281 cy.get($mainRow).scrollIntoView();
1282 label && cy.contains(label);
1285 cy.get($mainRow).nextUntil('[data-cy="process-io-param"]').as("secondaryRows");
1287 if (Array.isArray(val)) {
1288 val.forEach(v => cy.get("@secondaryRows").contains(v));
1290 cy.get("@secondaryRows").contains(val);
1294 cy.get("@secondaryRows").contains(collection);
1298 if (Array.isArray(val)) {
1299 val.forEach(v => cy.contains(v));
1305 cy.contains(collection);
1311 const verifyIOParameterImage = (name, url) => {
1316 cy.get('[alt="Inline Preview"]')
1317 .should("be.visible")
1319 expect($img[0].naturalWidth).to.be.greaterThan(0);
1320 expect($img[0].src).contains(url);
1325 it("displays IO parameters with keep links and previews", function () {
1326 // Create output collection for real files
1327 cy.createCollection(adminUser.token, {
1328 name: `Test collection ${Math.floor(Math.random() * 999999)}`,
1329 owner_uuid: activeUser.user.uuid,
1330 }).then(testOutputCollection => {
1331 cy.loginAs(activeUser);
1333 cy.goToPath(`/collections/${testOutputCollection.uuid}`);
1335 cy.get("[data-cy=upload-button]").click();
1337 cy.fixture("files/cat.png", "base64").then(content => {
1338 cy.get("[data-cy=drag-and-drop]").upload(content, "cat.png");
1339 cy.get("[data-cy=form-submit-btn]").click();
1340 cy.waitForDom().get("[data-cy=form-submit-btn]").should("not.exist");
1341 // Confirm final collection state.
1342 cy.get("[data-cy=collection-files-panel]").contains("cat.png").should("exist");
1345 cy.getCollection(activeUser.token, testOutputCollection.uuid).as("testOutputCollection");
1348 // Get updated collection pdh
1349 cy.getAll("@testOutputCollection").then(([testOutputCollection]) => {
1350 // Add output uuid and inputs to container request
1351 cy.intercept({ method: "GET", url: "**/arvados/v1/container_requests/*" }, req => {
1352 req.on('response', res => {
1353 res.body.output_uuid = testOutputCollection.uuid;
1354 res.body.mounts["/var/lib/cwl/cwl.input.json"] = {
1355 content: testInputs.map(param => param.input).reduce((acc, val) => Object.assign(acc, val), {}),
1357 res.body.mounts["/var/lib/cwl/workflow.json"] = {
1362 inputs: testInputs.map(input => input.definition),
1363 outputs: testOutputs.map(output => output.definition),
1371 // Stub fake output collection
1373 { method: "GET", url: `**/arvados/v1/collections/${testOutputCollection.uuid}*` },
1377 uuid: testOutputCollection.uuid,
1378 portable_data_hash: testOutputCollection.portable_data_hash,
1383 // Stub fake output json
1385 { method: "GET", url: "**/c%3Dzzzzz-4zz18-zzzzzzzzzzzzzzz/cwl.output.json" },
1388 body: testOutputs.map(param => param.output).reduce((acc, val) => Object.assign(acc, val), {}),
1392 // Stub webdav response, points to output json
1394 { method: "PROPFIND", url: "*" },
1396 fixture: "webdav-propfind-outputs.xml",
1401 createContainerRequest(activeUser, "test_container_request", "arvados/jobs", ["echo", "hello world"], false, "Committed").as(
1405 cy.getAll("@containerRequest", "@testOutputCollection").then(function ([containerRequest, testOutputCollection]) {
1406 cy.goToPath(`/processes/${containerRequest.uuid}`);
1407 cy.get("[data-cy=process-io-card] h6")
1408 .contains("Input Parameters")
1409 .parents("[data-cy=process-io-card]")
1411 cy.get(ctx).scrollIntoView();
1412 verifyIOParameter("input_file", null, "Label Description", "input1.tar", "00000000000000000000000000000000+01");
1413 verifyIOParameter("input_file", null, "Label Description", "input1-2.txt", undefined, true);
1414 verifyIOParameter("input_file", null, "Label Description", "input1-3.txt", undefined, true);
1415 verifyIOParameter("input_file", null, "Label Description", "input1-4.txt", undefined, true);
1416 verifyIOParameter("input_dir", null, "Doc Description", "/", "11111111111111111111111111111111+01");
1417 verifyIOParameter("input_bool", null, "Doc desc 1, Doc desc 2", "true");
1418 verifyIOParameter("input_int", null, null, "1");
1419 verifyIOParameter("input_long", null, null, "1");
1420 verifyIOParameter("input_float", null, null, "1.5");
1421 verifyIOParameter("input_double", null, null, "1.3");
1422 verifyIOParameter("input_string", null, null, "Hello World");
1423 verifyIOParameter("input_file_array", null, null, "input2.tar", "00000000000000000000000000000000+02");
1424 verifyIOParameter("input_file_array", null, null, "input3.tar", undefined, true);
1425 verifyIOParameter("input_file_array", null, null, "input3-2.txt", undefined, true);
1426 verifyIOParameter("input_file_array", null, null, "Cannot display value", undefined, true);
1427 verifyIOParameter("input_dir_array", null, null, "/", "11111111111111111111111111111111+02");
1428 verifyIOParameter("input_dir_array", null, null, "/", "11111111111111111111111111111111+03", true);
1429 verifyIOParameter("input_dir_array", null, null, "Cannot display value", undefined, true);
1430 verifyIOParameter("input_int_array", null, null, ["1", "3", "5", "Cannot display value"]);
1431 verifyIOParameter("input_long_array", null, null, ["10", "20", "Cannot display value"]);
1432 verifyIOParameter("input_float_array", null, null, ["10.2", "10.4", "10.6", "Cannot display value"]);
1433 verifyIOParameter("input_double_array", null, null, ["20.1", "20.2", "20.3", "Cannot display value"]);
1434 verifyIOParameter("input_string_array", null, null, ["Hello", "World", "!", "Cannot display value"]);
1435 verifyIOParameter("input_bool_include", null, null, "Cannot display value");
1436 verifyIOParameter("input_int_include", null, null, "Cannot display value");
1437 verifyIOParameter("input_float_include", null, null, "Cannot display value");
1438 verifyIOParameter("input_string_include", null, null, "Cannot display value");
1439 verifyIOParameter("input_file_include", null, null, "Cannot display value");
1440 verifyIOParameter("input_directory_include", null, null, "Cannot display value");
1441 verifyIOParameter("input_file_url", null, null, "http://example.com/index.html");
1443 cy.get("[data-cy=process-io-card] h6")
1444 .contains("Output Parameters")
1445 .parents("[data-cy=process-io-card]")
1447 cy.get(ctx).scrollIntoView();
1448 const outPdh = testOutputCollection.portable_data_hash;
1450 verifyIOParameter("output_file", null, "Label Description", "cat.png", `${outPdh}`);
1451 // Disabled until image preview returns
1452 // verifyIOParameterImage("output_file", `/c=${outPdh}/cat.png`);
1453 verifyIOParameter("output_file_with_secondary", null, "Doc Description", "main.dat", `${outPdh}`);
1454 verifyIOParameter("output_file_with_secondary", null, "Doc Description", "secondary.dat", undefined, true);
1455 verifyIOParameter("output_file_with_secondary", null, "Doc Description", "secondary2.dat", undefined, true);
1456 verifyIOParameter("output_dir", null, "Doc desc 1, Doc desc 2", "outdir1", `${outPdh}`);
1457 verifyIOParameter("output_bool", null, null, "true");
1458 verifyIOParameter("output_int", null, null, "1");
1459 verifyIOParameter("output_long", null, null, "1");
1460 verifyIOParameter("output_float", null, null, "100.5");
1461 verifyIOParameter("output_double", null, null, "100.3");
1462 verifyIOParameter("output_string", null, null, "Hello output");
1463 verifyIOParameter("output_file_array", null, null, "output2.tar", `${outPdh}`);
1464 verifyIOParameter("output_file_array", null, null, "output3.tar", undefined, true);
1465 verifyIOParameter("output_dir_array", null, null, "outdir2", `${outPdh}`);
1466 verifyIOParameter("output_dir_array", null, null, "outdir3", undefined, true);
1467 verifyIOParameter("output_int_array", null, null, ["10", "11", "12"]);
1468 verifyIOParameter("output_long_array", null, null, ["51", "52"]);
1469 verifyIOParameter("output_float_array", null, null, ["100.2", "100.4", "100.6"]);
1470 verifyIOParameter("output_double_array", null, null, ["100.1", "100.2", "100.3"]);
1471 verifyIOParameter("output_string_array", null, null, ["Hello", "Output", "!"]);
1476 it("displays IO parameters with no value", function () {
1477 const fakeOutputUUID = "zzzzz-4zz18-abcdefghijklmno";
1478 const fakeOutputPDH = "11111111111111111111111111111111+99/";
1480 cy.loginAs(activeUser);
1482 // Add output uuid and inputs to container request
1483 cy.intercept({ method: "GET", url: "**/arvados/v1/container_requests/*" }, req => {
1484 req.on('response', res => {
1485 res.body.output_uuid = fakeOutputUUID;
1486 res.body.mounts["/var/lib/cwl/cwl.input.json"] = {
1489 res.body.mounts["/var/lib/cwl/workflow.json"] = {
1494 inputs: testInputs.map(input => input.definition),
1495 outputs: testOutputs.map(output => output.definition),
1503 // Stub fake output collection
1505 { method: "GET", url: `**/arvados/v1/collections/${fakeOutputUUID}*` },
1509 uuid: fakeOutputUUID,
1510 portable_data_hash: fakeOutputPDH,
1515 // Stub fake output json
1517 { method: "GET", url: `**/c%3D${fakeOutputUUID}/cwl.output.json` },
1524 cy.readFile("cypress/fixtures/webdav-propfind-outputs.xml").then(data => {
1525 // Stub webdav response, points to output json
1527 { method: "PROPFIND", url: "*" },
1530 body: data.replace(/zzzzz-4zz18-zzzzzzzzzzzzzzz/g, fakeOutputUUID),
1535 createContainerRequest(activeUser, "test_container_request", "arvados/jobs", ["echo", "hello world"], false, "Committed").as(
1539 cy.getAll("@containerRequest").then(function ([containerRequest]) {
1540 cy.goToPath(`/processes/${containerRequest.uuid}`);
1543 cy.get("[data-cy=process-io-card] h6")
1544 .contains("Input Parameters")
1545 .parents("[data-cy=process-io-card]")
1547 cy.get(ctx).scrollIntoView();
1551 testInputs.map((input) => {
1552 verifyIOParameter(input.definition.id.split('/').slice(-1)[0], null, null, "No value");
1555 cy.get("[data-cy=process-io-card] h6")
1556 .contains("Output Parameters")
1557 .parents("[data-cy=process-io-card]")
1559 cy.get(ctx).scrollIntoView();
1561 testOutputs.map((output) => {
1562 verifyIOParameter(output.definition.id.split('/').slice(-1)[0], null, null, "No value");