// Copyright (C) The Arvados Authors. All rights reserved. // // SPDX-License-Identifier: AGPL-3.0 import React from "react"; import { CustomStyleRulesCallback } from 'common/custom-theme'; import { Grid, Typography } from "@mui/material"; import withStyles from '@mui/styles/withStyles'; import { Dispatch } from 'redux'; import { formatCost, formatDate } from "common/formatters"; import { resourceLabel } from "common/labels"; import { DetailsAttribute } from "components/details-attribute/details-attribute"; import { ResourceKind } from "models/resource"; import { CollectionName, ContainerRunTime, ResourceWithName } from "views-components/data-explorer/renderers"; import { getProcess, getProcessStatus, ProcessProperties } from "store/processes/process"; import { RootState } from "store/store"; import { connect } from "react-redux"; import { ProcessResource, MOUNT_PATH_CWL_WORKFLOW } from "models/process"; import { ContainerResource } from "models/container"; import { navigateToOutput, openWorkflow } from "store/process-panel/process-panel-actions"; import { ArvadosTheme } from "common/custom-theme"; import { ProcessRuntimeStatus } from "views-components/process-runtime-status/process-runtime-status"; import { getPropertyChip } from "views-components/resource-properties-form/property-chip"; import { ContainerRequestResource } from "models/container-request"; import { filterResources } from "store/resources/resources"; import { JSONMount, MountType } from 'models/mount-types'; import { getCollectionUrl } from 'models/collection'; import { Link } from "react-router-dom"; import { getResourceUrl } from "routes/routes"; import WarningIcon from '@mui/icons-material/Warning'; import { ResourcesState } from "store/resources/resources"; type CssRules = 'link' | 'propertyTag'; const styles: CustomStyleRulesCallback = (theme: ArvadosTheme) => ({ link: { fontSize: '0.875rem', color: theme.palette.primary.main, '&:hover': { cursor: 'pointer' } }, propertyTag: { marginRight: theme.spacing(0.5), marginBottom: theme.spacing(0.5) }, }); const mapStateToProps = (state: RootState, props: { request: ProcessResource, container?: ContainerResource }) => { return { requestUuid: props.request.uuid, resources: state.resources, }; }; interface ProcessDetailsAttributesActionProps { navigateToOutput: (resource: ContainerRequestResource) => void; openWorkflow: (uuid: string) => void; } const mapDispatchToProps = (dispatch: Dispatch): ProcessDetailsAttributesActionProps => ({ navigateToOutput: (resource) => dispatch(navigateToOutput(resource)), openWorkflow: (uuid) => dispatch(openWorkflow(uuid)), }); type ProcessDetailsDataProps = { request: ProcessResource, container?: ContainerResource, twoCol?: boolean, hideProcessPanelRedundantFields?: boolean, classes: Record requestUuid: string; resources: ResourcesState; } export const ProcessDetailsAttributes = withStyles(styles, { withTheme: true })( connect(mapStateToProps, mapDispatchToProps)( (props: ProcessDetailsDataProps & ProcessDetailsAttributesActionProps) => { const process = getProcess(props.request.uuid)(props.resources); const subprocesses = filterResources((resource: ContainerRequestResource) => (resource.kind === ResourceKind.CONTAINER_REQUEST && resource.requestingContainerUuid === process?.containerRequest.containerUuid) )(props.resources) const mounts = process?.containerRequest?.mounts; const containerRequest = process?.containerRequest; const container = props.container; const classes = props.classes; const mdSize = props.twoCol ? 6 : 12; const { workflowCollection, workflowPath } = parseMounts(mounts); const filteredPropertyKeys = Object.keys(containerRequest?.properties) .filter(k => (typeof containerRequest?.properties[k] !== 'object')); const hasTotalCost = containerRequest && containerRequest.cumulativeCost > 0; const totalCostNotReady = container && container.cost > 0 && container.state === "Running" && containerRequest && containerRequest.cumulativeCost === 0 && subprocesses.length > 0; const resubmittedUrl = containerRequest && getResourceUrl(containerRequest.properties[ProcessProperties.FAILED_CONTAINER_RESUBMITTED]); function parseMounts(mounts: { [path: string]: MountType } | undefined) { if (!mounts || !mounts[MOUNT_PATH_CWL_WORKFLOW]) { return { workflowCollection: "", workflowPath: "" }; } const wf = mounts[MOUNT_PATH_CWL_WORKFLOW] as JSONMount; let workflowCollection = ""; let workflowPath = ""; if (wf.content) { if (wf.content["$graph"] && wf.content["$graph"].length > 0 && wf.content["$graph"][0] && wf.content["$graph"][0]["steps"] && wf.content["$graph"][0]["steps"][0]) { const REGEX = /keep:([0-9a-f]{32}\+\d+)\/(.*)/; const pdh = wf.content["$graph"][0]["steps"][0].run.match(REGEX); if (pdh) { workflowCollection = pdh[1]; workflowPath = pdh[2]; } } } return { workflowCollection, workflowPath }; } if (!containerRequest) return <>; return {!props.hideProcessPanelRedundantFields && } {resubmittedUrl && This process failed but was automatically resubmitted. Click here to go to the resubmitted process. } } /> {!props.hideProcessPanelRedundantFields && } {(containerRequest && containerRequest.modifiedByUserUuid) && } /> } {(container && container.runtimeUserUuid && container.runtimeUserUuid !== containerRequest.modifiedByUserUuid) && } /> } {containerRequest.outputUuid && props.navigateToOutput(containerRequest!)}> } {container && 0 ? formatCost(container.cost) : 'not available'} for this container` } /> } {container && workflowCollection && } {containerRequest.properties.template_uuid && props.openWorkflow(containerRequest.properties.template_uuid)}> } {/* NOTE: The property list should be kept at the bottom, because it spans the entire available width, without regards of the twoCol prop. */} {filteredPropertyKeys.length > 0 ? filteredPropertyKeys.map(k => Array.isArray(containerRequest.properties[k]) ? containerRequest.properties[k].map((v: string) => getPropertyChip(k, v, undefined, classes.propertyTag)) : getPropertyChip(k, containerRequest.properties[k], undefined, classes.propertyTag)) :
No properties
}
; } ) );