blob: 4520c20a39b12b7da72da30fc58046e7261e39e2 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import { Intent, Label, ProgressBar } from '@blueprintjs/core';
import React, { useState } from 'react';
import { Execution } from '../../../druid-models';
import { CancelQueryDialog } from '../cancel-query-dialog/cancel-query-dialog';
import './execution-progress-bar-pane.scss';
export interface ExecutionProgressBarPaneProps {
execution: Execution | undefined;
onCancel?(message?: string): void;
onToggleLiveReports?(): void;
showLiveReports?: boolean;
}
export const ExecutionProgressBarPane = React.memo(function ExecutionProgressBarPane(
props: ExecutionProgressBarPaneProps,
) {
const { execution, onCancel, onToggleLiveReports, showLiveReports } = props;
const [showCancelConfirm, setShowCancelConfirm] = useState<string | undefined>();
const stages = execution?.stages;
function cancelMaybeConfirm(message: string) {
if (!onCancel) return;
if (execution?.isProcessingData()) {
setShowCancelConfirm(message);
} else {
onCancel(message);
}
}
const idx = stages ? stages.currentStageIndex() : -1;
const waitingForSegments = stages && !execution.isWaitingForQuery();
const segmentStatusDescription = execution?.getSegmentStatusDescription();
return (
<div className="execution-progress-bar-pane">
<Label>
{Execution.getProgressDescription(execution)}
{onCancel && (
<>
{' '}
<span
className="cancel"
onClick={() =>
cancelMaybeConfirm(
waitingForSegments
? 'Task completed. Skipped waiting for segments to be loaded.'
: 'Task has been canceled.',
)
}
>
{waitingForSegments ? '(skip waiting)' : '(cancel)'}
</span>
</>
)}
</Label>
<ProgressBar
className="overall"
key={stages ? 'actual' : 'pending'}
intent={stages ? Intent.PRIMARY : undefined}
value={stages && execution.isWaitingForQuery() ? stages.overallProgress() : undefined}
/>
{segmentStatusDescription && <Label>{segmentStatusDescription.label}</Label>}
{stages && idx >= 0 && (
<>
<Label>{`Current stage (${idx + 1} of ${stages.stageCount()})`}</Label>
<ProgressBar
className="stage"
stripes={false}
value={stages.stageProgress(stages.getStage(idx))}
/>
{onToggleLiveReports && (
<Label className="toggle-live-reports" onClick={onToggleLiveReports}>
{showLiveReports ? 'Hide live reports' : 'Show live reports'}
</Label>
)}
</>
)}
{showCancelConfirm && onCancel && (
<CancelQueryDialog
onCancel={() => onCancel(showCancelConfirm)}
onDismiss={() => setShowCancelConfirm(undefined)}
/>
)}
</div>
);
});