Files
windmill/frontend/src/lib/components/flows/FlowProgressBar.svelte
2023-08-20 10:17:06 +02:00

89 lines
2.0 KiB
Svelte

<script lang="ts">
import { FlowStatusModule, Job } from '$lib/gen'
import ProgressBar from '../progressBar/ProgressBar.svelte'
export let job: Job | undefined = undefined
let error: number | undefined = undefined
let index = 0
let subIndex: number | undefined = undefined
let subLength: number | undefined = undefined
let length = 1
let nextInProgress = false
$: if (job) updateJobProgress(job)
function updateJobProgress(job: Job) {
const modules = job?.flow_status?.modules
if (!modules?.length) {
return
}
let subStepIndex: undefined | number = undefined
let subStepLength: undefined | number = undefined
let newError: number | undefined = undefined
let newNextInProgress = false
let maxDone = job?.flow_status?.step ?? 0
if (modules.length > maxDone) {
const nextModule = modules[maxDone]
if (nextModule.type === FlowStatusModule.type.IN_PROGRESS) {
newNextInProgress = true
}
}
let module = modules[maxDone]
if (module) {
if (
module.type === FlowStatusModule.type.FAILURE ||
(module.type === FlowStatusModule.type.SUCCESS && job['success'] === false)
) {
newError = maxDone
maxDone = maxDone + 1
}
}
// Loop is still iterating
if (module?.iterator) {
const stepIndex = module.iterator.index || 0
const stepLength = module.iterator.itered?.length || 0
if (module.iterator.index != undefined) {
subStepIndex = stepIndex
subStepLength = stepLength
}
} else if (module?.branchall) {
subStepIndex = module.branchall.branch
subStepLength = module.branchall.len
}
error = newError
subLength = subStepLength ? Math.max(subStepLength, 1) : undefined
subIndex = subStepIndex
length = Math.max(modules.length, 1)
index = maxDone
nextInProgress = newNextInProgress
}
let resetP: any
export function reset() {
resetP?.()
error = undefined
subIndex = undefined
subLength = undefined
length = 1
index = 0
}
</script>
<ProgressBar
bind:resetP
{length}
{index}
{nextInProgress}
{subLength}
{subIndex}
{error}
class={$$props.class}
/>