diff --git a/frontend/src/lib/components/FlowJobResult.svelte b/frontend/src/lib/components/FlowJobResult.svelte index f89f5dbc51..787ef86c0a 100644 --- a/frontend/src/lib/components/FlowJobResult.svelte +++ b/frontend/src/lib/components/FlowJobResult.svelte @@ -13,25 +13,37 @@ export let filename: string | undefined = undefined export let jobId: string | undefined = undefined export let workspaceId: string | undefined = undefined + export let refreshLog: boolean = false $: jobId && logs == undefined && getLogs() + let logOffset = 0 async function getLogs() { if (jobId) { const getUpdate = await JobService.getJobUpdates({ workspace: workspaceId ?? $workspaceStore!, id: jobId, running: loading, - logOffset: 0 + logOffset: logOffset == 0 ? (logs?.length ? logs?.length + 1 : 0) : logOffset }) - logs = getUpdate.new_logs + logs = (logs ?? '').concat(getUpdate.new_logs ?? '') + logOffset = getUpdate.log_offset ?? 0 + } + if (refreshLog) { + setTimeout(() => { + if (refreshLog) { + getLogs() + } + }, 1000) } }
{job.logs}