X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/59caadc58a0b7ffc92fa95c90b16c99a9af6d942..1826bc21a34b983778f6e221b6c4004fdea1ad1d:/src/store/processes/process.ts diff --git a/src/store/processes/process.ts b/src/store/processes/process.ts index afd27b2e..ab8093b8 100644 --- a/src/store/processes/process.ts +++ b/src/store/processes/process.ts @@ -2,28 +2,42 @@ // // SPDX-License-Identifier: AGPL-3.0 -import { ContainerRequestResource } from '../../models/container-request'; -import { ContainerResource } from '../../models/container'; +import { ContainerRequestResource, ContainerRequestState } from '../../models/container-request'; +import { ContainerResource, ContainerState } from '../../models/container'; import { ResourcesState, getResource } from '~/store/resources/resources'; import { filterResources } from '../resources/resources'; -import { ResourceKind, Resource } from '~/models/resource'; +import { ResourceKind, Resource, extractUuidKind } from '~/models/resource'; import { getTimeDiff } from '~/common/formatters'; +import { ArvadosTheme } from '~/common/custom-theme'; export interface Process { containerRequest: ContainerRequestResource; container?: ContainerResource; } +export enum ProcessStatus { + CANCELLED = 'Cancelled', + COMPLETED = 'Completed', + DRAFT = 'Draft', + FAILED = 'Failed', + LOCKED = 'Locked', + QUEUED = 'Queued', + RUNNING = 'Running', + UNKNOWN = 'Unknown', +} + export const getProcess = (uuid: string) => (resources: ResourcesState): Process | undefined => { - const containerRequest = getResource(uuid)(resources); - if (containerRequest) { - if (containerRequest.containerUuid) { - const container = getResource(containerRequest.containerUuid)(resources); - if (container) { - return { containerRequest, container }; + if (extractUuidKind(uuid) === ResourceKind.CONTAINER_REQUEST) { + const containerRequest = getResource(uuid)(resources); + if (containerRequest) { + if (containerRequest.containerUuid) { + const container = getResource(containerRequest.containerUuid)(resources); + if (container) { + return { containerRequest, container }; + } } + return { containerRequest }; } - return { containerRequest }; } return; }; @@ -42,15 +56,53 @@ export const getSubprocesses = (uuid: string) => (resources: ResourcesState) => return []; }; -export const getProcessRuntime = (subprocess: Process) => - subprocess.container - ? getTimeDiff(subprocess.container.finishedAt || '', subprocess.container.startedAt || '') +export const getProcessRuntime = ({ container }: Process) => + container + ? getTimeDiff(container.finishedAt || '', container.startedAt || '') : 0; -export const getProcessStatus = (process: Process) => - process.container - ? process.container.state - : process.containerRequest.state; +export const getProcessStatusColor = (status: string, { customs, palette }: ArvadosTheme) => { + switch (status) { + case ProcessStatus.RUNNING: + return customs.colors.blue500; + case ProcessStatus.COMPLETED: + return customs.colors.green700; + case ProcessStatus.CANCELLED: + case ProcessStatus.FAILED: + return customs.colors.red900; + default: + return palette.grey["500"]; + } +}; + +export const getProcessStatus = ({ containerRequest, container }: Process): ProcessStatus => { + switch (true) { + case containerRequest.state === ContainerRequestState.UNCOMMITTED: + return ProcessStatus.DRAFT; + + case containerRequest.priority === 0: + case container && container.state === ContainerState.CANCELLED: + return ProcessStatus.CANCELLED; + + case container && container.state === ContainerState.QUEUED: + return ProcessStatus.QUEUED; + + case container && container.state === ContainerState.LOCKED: + return ProcessStatus.LOCKED; + + case container && container.state === ContainerState.RUNNING: + return ProcessStatus.RUNNING; + + case container && container.state === ContainerState.COMPLETE && container.exitCode === 0: + return ProcessStatus.COMPLETED; + + case container && container.state === ContainerState.COMPLETE && container.exitCode !== 0: + return ProcessStatus.FAILED; + + default: + return ProcessStatus.UNKNOWN; + } +}; const isSubprocess = (containerUuid: string) => (resource: Resource) => resource.kind === ResourceKind.CONTAINER_REQUEST