From bdf1bef2bd7e16fca00ba4839281efdaaf3a689f Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Sat, 6 Apr 2024 13:52:49 +0200
Subject: [PATCH] improve flow preview logs

---
 frontend/src/lib/components/FlowJobResult.svelte | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/frontend/src/lib/components/FlowJobResult.svelte b/frontend/src/lib/components/FlowJobResult.svelte
index 6a6790f15e..9c1fe32219 100644
--- a/frontend/src/lib/components/FlowJobResult.svelte
+++ b/frontend/src/lib/components/FlowJobResult.svelte
@@ -15,7 +15,18 @@
 	export let workspaceId: string | undefined = undefined
 	export let refreshLog: boolean = false
 
-	$: jobId && logs == undefined && getLogs()
+	let lastJobId: string | undefined = undefined
+
+	$: jobId != lastJobId && diffJobId()
+
+	async function diffJobId() {
+		if (jobId != lastJobId) {
+			lastJobId = jobId
+			logs = undefined
+			logOffset = 0
+			getLogs()
+		}
+	}
 
 	let logOffset = 0
 	async function getLogs() {
@@ -23,7 +34,7 @@
 			const getUpdate = await JobService.getJobUpdates({
 				workspace: workspaceId ?? $workspaceStore!,
 				id: jobId,
-				running: loading,
+				running: loading ?? false,
 				logOffset: logOffset == 0 ? (logs?.length ? logs?.length + 1 : 0) : logOffset
 			})
 			logs = (logs ?? '').concat(getUpdate.new_logs ?? '')