From 91c1dbebf80d0f6111ebc971b580ce08dc796d4c Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@windmill.dev>
Date: Thu, 12 Feb 2026 15:52:21 +0000
Subject: [PATCH] nit fork flow

---
 .../(root)/(logged)/flows/add/+page.svelte    | 25 +++++++++++++++++--
 .../(root)/(logged)/run/[...run]/+page.svelte | 13 +++++++---
 2 files changed, 32 insertions(+), 6 deletions(-)

diff --git a/frontend/src/routes/(root)/(logged)/flows/add/+page.svelte b/frontend/src/routes/(root)/(logged)/flows/add/+page.svelte
index a3e9535474..a3099e2be9 100644
--- a/frontend/src/routes/(root)/(logged)/flows/add/+page.svelte
+++ b/frontend/src/routes/(root)/(logged)/flows/add/+page.svelte
@@ -27,7 +27,24 @@
 	const hubId = $page.url.searchParams.get('hub')
 	const templatePath = $page.url.searchParams.get('template')
 	const templateId = $page.url.searchParams.get('template_id')
-	const initialState = hubId || templatePath || nodraft ? undefined : localStorage.getItem('flow')
+	const isFork = $page.url.searchParams.get('fork')
+
+	let forkState: any = undefined
+	if (isFork) {
+		const forkJson = localStorage.getItem('fork_flow')
+		if (forkJson) {
+			try {
+				forkState = JSON.parse(forkJson)
+			} catch {}
+			localStorage.removeItem('fork_flow')
+		} else if ((window.opener as any)?.__forkPreviewData) {
+			forkState = (window.opener as any).__forkPreviewData
+			delete (window.opener as any).__forkPreviewData
+		}
+	}
+
+	const initialState =
+		hubId || templatePath || nodraft || isFork ? undefined : localStorage.getItem('flow')
 
 	let selectedId: string = $state('settings-metadata')
 	let loading = $state(false)
@@ -40,6 +57,7 @@
 		initialArgs = $initialArgsStore
 		$initialArgsStore = undefined
 	}
+	// initialArgs may also be set from decoded state below (e.g. fork preview)
 	let flowBuilder: FlowBuilder | undefined = $state(undefined)
 
 	const flowStore: StateStore<Flow> = $state({
@@ -71,7 +89,7 @@
 			schema: emptySchema()
 		}
 
-		let state = initialState ? decodeState(initialState) : undefined
+		let state = forkState ?? (initialState ? decodeState(initialState) : undefined)
 		const initialStateQuery = $page.url.hash != '' ? $page.url.hash.slice(1) : undefined
 
 		if (initialStateQuery) {
@@ -102,6 +120,9 @@
 
 			flow = state.flow
 			pathStoreInit = state.path
+			if (state.initialArgs) {
+				initialArgs = state.initialArgs
+			}
 			draftTriggersFromUrl = state.draft_triggers
 			selectedTriggerIndexFromUrl = state.selected_trigger
 			flowBuilder?.setDraftTriggers(draftTriggersFromUrl)
diff --git a/frontend/src/routes/(root)/(logged)/run/[...run]/+page.svelte b/frontend/src/routes/(root)/(logged)/run/[...run]/+page.svelte
index 079b932b53..22d5474987 100644
--- a/frontend/src/routes/(root)/(logged)/run/[...run]/+page.svelte
+++ b/frontend/src/routes/(root)/(logged)/run/[...run]/+page.svelte
@@ -283,13 +283,18 @@
 
 	function forkPreview() {
 		if (isFlowPreview(job?.job_kind)) {
-			$initialArgsStore = job?.args
 			const state = {
 				flow: { value: job?.raw_flow },
-				path: job?.script_path + '_fork'
+				path: job?.script_path + '_fork',
+				initialArgs: job?.args
 			}
-			const encodedArgs = encodeState(job?.args)
-			window.open(`/flows/add?initial_args=${encodedArgs}#${encodeState(state)}`)
+			try {
+				localStorage.setItem('fork_flow', JSON.stringify(state))
+			} catch {
+				// Flow too large for localStorage, pass via window reference
+				;(window as any).__forkPreviewData = state
+			}
+			window.open('/flows/add?fork=true')
 		} else {
 			$initialArgsStore = job?.args
 			let n: NewScript = {