import Checkbox from "@material-ui/core/Checkbox"; import IconButton from "@material-ui/core/IconButton"; import TableCell from "@material-ui/core/TableCell"; import TableRow from "@material-ui/core/TableRow"; import Tooltip from "@material-ui/core/Tooltip"; import ArchiveIcon from "@material-ui/icons/Archive"; import DeleteIcon from "@material-ui/icons/Delete"; import FileCopyOutlinedIcon from "@material-ui/icons/FileCopyOutlined"; import MoreHorizIcon from "@material-ui/icons/MoreHoriz"; import PlayArrowIcon from "@material-ui/icons/PlayArrow"; import React from "react"; import { connect, ConnectedProps } from "react-redux"; import { useHistory } from "react-router-dom"; import { taskRowsPerPageChange } from "../actions/settingsActions"; import { archiveAllRetryTasksAsync, archiveRetryTaskAsync, batchArchiveRetryTasksAsync, batchDeleteRetryTasksAsync, batchRunRetryTasksAsync, deleteAllRetryTasksAsync, deleteRetryTaskAsync, listRetryTasksAsync, runAllRetryTasksAsync, runRetryTaskAsync, } from "../actions/tasksActions"; import TasksTable, { RowProps, useRowStyles } from "./TasksTable"; import { taskDetailsPath } from "../paths"; import { AppState } from "../store"; import { TableColumn } from "../types/table"; import { durationBefore, prettifyPayload, uuidPrefix } from "../utils"; import SyntaxHighlighter from "./SyntaxHighlighter"; function mapStateToProps(state: AppState) { return { loading: state.tasks.retryTasks.loading, error: state.tasks.retryTasks.error, tasks: state.tasks.retryTasks.data, batchActionPending: state.tasks.retryTasks.batchActionPending, allActionPending: state.tasks.retryTasks.allActionPending, pollInterval: state.settings.pollInterval, pageSize: state.settings.taskRowsPerPage, }; } const mapDispatchToProps = { batchDeleteTasks: batchDeleteRetryTasksAsync, batchRunTasks: batchRunRetryTasksAsync, batchArchiveTasks: batchArchiveRetryTasksAsync, deleteAllTasks: deleteAllRetryTasksAsync, runAllTasks: runAllRetryTasksAsync, archiveAllTasks: archiveAllRetryTasksAsync, listTasks: listRetryTasksAsync, deleteTask: deleteRetryTaskAsync, runTask: runRetryTaskAsync, archiveTask: archiveRetryTaskAsync, taskRowsPerPageChange, }; const connector = connect(mapStateToProps, mapDispatchToProps); type ReduxProps = ConnectedProps; interface Props { queue: string; // name of the queue. totalTaskCount: number; // totoal number of scheduled tasks. } const columns: TableColumn[] = [ { key: "id", label: "ID", align: "left" }, { key: "type", label: "Type", align: "left" }, { key: "payload", label: "Payload", align: "left" }, { key: "retry_in", label: "Retry In", align: "left" }, { key: "last_error", label: "Last Error", align: "left" }, { key: "retried", label: "Retried", align: "right" }, { key: "max_retry", label: "Max Retry", align: "right" }, { key: "actions", label: "Actions", align: "center" }, ]; function Row(props: RowProps) { const { task } = props; const classes = useRowStyles(); const history = useHistory(); return ( history.push(taskDetailsPath(task.queue, task.id))} > {!window.READ_ONLY && ( e.stopPropagation()}> ) => props.onSelectChange(event.target.checked) } checked={props.isSelected} /> )}
{uuidPrefix(task.id)} { e.stopPropagation(); navigator.clipboard.writeText(task.id); }} size="small" className={classes.copyButton} >
{task.type} {prettifyPayload(task.payload)} {durationBefore(task.next_process_at)} {task.error_message} {task.retried} {task.max_retry} {!window.READ_ONLY && ( e.stopPropagation()} > {props.showActions ? ( ) : ( )} )}
); } function RetryTasksTable(props: Props & ReduxProps) { return ( } {...props} /> ); } export default connector(RetryTasksTable);