66 lines
1.7 KiB
Svelte
66 lines
1.7 KiB
Svelte
<script lang="ts">
|
|
import { writable, type Writable } from 'svelte/store'
|
|
import FlowStatusViewerInner from './FlowStatusViewerInner.svelte'
|
|
import type { FlowState } from './flows/flowState'
|
|
import { createEventDispatcher, setContext } from 'svelte'
|
|
import type { FlowStatusViewerContext } from './graph'
|
|
import { isOwner as loadIsOwner } from '$lib/utils'
|
|
import { userStore, workspaceStore } from '$lib/stores'
|
|
|
|
export let jobId: string
|
|
export let workspaceId: string | undefined = undefined
|
|
export let flowStateStore: Writable<FlowState> = writable({})
|
|
export let selectedJobStep: string | undefined = undefined
|
|
|
|
export let isOwner = false
|
|
export let wideResults = false
|
|
|
|
let lastJobId: string = jobId
|
|
|
|
let retryStatus = writable({})
|
|
let suspendStatus = writable({})
|
|
setContext<FlowStatusViewerContext>('FlowStatusViewer', {
|
|
flowStateStore,
|
|
suspendStatus,
|
|
retryStatus
|
|
})
|
|
|
|
function loadOwner(path: string) {
|
|
isOwner = loadIsOwner(path, $userStore!, workspaceId ?? $workspaceStore!)
|
|
}
|
|
|
|
async function updateJobId() {
|
|
if (jobId !== lastJobId) {
|
|
lastJobId = jobId
|
|
$retryStatus = {}
|
|
$suspendStatus = {}
|
|
}
|
|
}
|
|
|
|
const dispatch = createEventDispatcher()
|
|
|
|
let lastScriptPath: string | undefined = undefined
|
|
|
|
$: jobId && updateJobId()
|
|
</script>
|
|
|
|
<FlowStatusViewerInner
|
|
on:jobsLoaded={({ detail }) => {
|
|
let { job } = detail
|
|
if (job.script_path != lastScriptPath && job.script_path) {
|
|
lastScriptPath = job.script_path
|
|
loadOwner(lastScriptPath ?? '')
|
|
}
|
|
dispatch('jobsLoaded', job)
|
|
}}
|
|
globalDurationStatuses={[]}
|
|
globalModuleStates={[]}
|
|
bind:selectedNode={selectedJobStep}
|
|
on:start
|
|
on:done
|
|
{jobId}
|
|
{workspaceId}
|
|
{isOwner}
|
|
{wideResults}
|
|
/>
|