Add run Id when fetching initial workflow values for workflow start

src/lib/components/workflow-actions.svelte

@@ -199,6 +199,7 @@
                 routeForWorkflowStart({
                   namespace,
                   workflowId: workflow.id,
+                  runId: workflow.runId,
                   taskQueue: workflow.taskQueue,
                   workflowType: workflow.name,
                 }),
@@ -234,6 +235,7 @@
               routeForWorkflowStart({
                 namespace,
                 workflowId: workflow.id,
+                runId: workflow.runId,
                 taskQueue: workflow.taskQueue,
                 workflowType: workflow.name,
               }),

src/lib/components/workflow/start-workflow-button.svelte

@@ -8,12 +8,14 @@
 
   export let namespace: string;
   export let workflowId: string;
+  export let runId: string;
   export let taskQueue: string;
   export let workflowType: string;
 
   $: href = routeForWorkflowStart({
     namespace,
     workflowId,
+    runId,
     taskQueue,
     workflowType,
   });

src/lib/components/workflow/workflows-summary-configurable-table/table-row.svelte

@@ -67,6 +67,7 @@
       {#if !workflowCreateDisabled($page)}
         <StartWorkflowButton
           {namespace}
+          runId={workflow.runId}
           workflowId={workflow.id}
           taskQueue={workflow.taskQueue}
           workflowType={workflow.name}

src/lib/pages/start-workflow.svelte

@@ -59,6 +59,7 @@
   let messageType = '';
   let workflowStartDelay = '';
 
+  let initialRunId = '';
   let initialWorkflowId = '';
   let initialWorkflowType = '';
 
@@ -96,11 +97,16 @@
     workflowId = $page.url.searchParams.get('workflowId') || '';
     taskQueue = $page.url.searchParams.get('taskQueue') || '';
     workflowType = $page.url.searchParams.get('workflowType') || '';
+    initialRunId = $page.url.searchParams.get('runId') || '';
     initialWorkflowId = $page.url.searchParams.get('workflowId') || '';
     initialWorkflowType = $page.url.searchParams.get('workflowType') || '';
 
-    if (initialWorkflowId || initialWorkflowType) {
-      getInitialValues(initialWorkflowId, initialWorkflowType);
+    if (initialWorkflowId || initialWorkflowType || initialRunId) {
+      getInitialValues({
+        runId: initialRunId,
+        workflowId: initialWorkflowId,
+        workflowType: initialWorkflowType,
+      });
     }
   });
 
@@ -158,11 +164,20 @@
     }
   };
 
-  const getInitialValues = async (id: string, type: string) => {
+  const getInitialValues = async ({
+    runId,
+    workflowId,
+    workflowType,
+  }: {
+    runId: string;
+    workflowId: string;
+    workflowType: string;
+  }) => {
     const initialValues = await fetchInitialValuesForStartWorkflow({
       namespace,
-      workflowId: id,
-      workflowType: type,
+      runId,
+      workflowId,
+      workflowType,
     });
     input = initialValues.input;
     encoding.set(initialValues.encoding);

src/lib/services/workflow-service.ts

@@ -656,10 +656,12 @@ export async function startWorkflow({
 
 export const fetchInitialValuesForStartWorkflow = async ({
   namespace,
+  runId,
   workflowType,
   workflowId,
 }: {
   namespace: string;
+  runId?: string;
   workflowType?: string;
   workflowId?: string;
 }): Promise<{
@@ -682,15 +684,18 @@ export const fetchInitialValuesForStartWorkflow = async ({
     details: '',
   };
   try {
-    let query = '';
-    if (workflowType && workflowId) {
-      query = `WorkflowType = "${workflowType}" AND WorkflowId = "${workflowId}"`;
-    } else if (workflowType) {
-      query = `WorkflowType = "${workflowType}"`;
-    } else if (workflowId) {
-      query = `WorkflowId = "${workflowId}"`;
+    const searchParams = [];
+    if (runId) {
+      searchParams.push(`RunId = "${runId}"`);
+    }
+    if (workflowType) {
+      searchParams.push(`WorkflowType = "${workflowType}"`);
+    }
+    if (workflowId) {
+      searchParams.push(`WorkflowId = "${workflowId}"`);
     }
 
+    const query = searchParams.join(' AND ');
     const route = routeForApi('workflows', { namespace });
     const workflows = await requestFromAPI<ListWorkflowExecutionsResponse>(
       route,

src/lib/utilities/route-for.ts

@@ -94,15 +94,22 @@ export const routeForWorkflows = (parameters: NamespaceParameter): string => {
 };
 
 type StartWorkflowParameters = NamespaceParameter &
-  Partial<{ workflowId: string; taskQueue: string; workflowType: string }>;
+  Partial<{
+    workflowId: string;
+    runId: string;
+    taskQueue: string;
+    workflowType: string;
+  }>;
 export const routeForWorkflowStart = ({
   namespace,
   workflowId,
+  runId,
   taskQueue,
   workflowType,
 }: StartWorkflowParameters): string => {
   return toURL(`${routeForNamespace({ namespace })}/workflows/start-workflow`, {
     workflowId: workflowId || '',
+    runId: runId || '',
     taskQueue: taskQueue || '',
     workflowType: workflowType || '',
   });