fix: improve wm_labels indices + UX nits

windmill-labs · Sep 4, 2024 · e934d2b · e934d2b
1 parent a7a08cf
commit e934d2b
Show file tree

Hide file tree

Showing 7 changed files with 40 additions and 24 deletions.
diff --git a/backend/windmill-api/src/db.rs b/backend/windmill-api/src/db.rs
@@ -142,7 +142,7 @@ impl Migrate for CustomMigrator {
                     "DROP INDEX CONCURRENTLY IF EXISTS labeled_jobs_on_jobs"
                 ).execute(&mut *self.inner).await?;
                 sqlx::query!(
-                    "CREATE INDEX CONCURRENTLY labeled_jobs_on_jobs ON completed_job USING GIN ((result -> 'wm_labels')) WHERE result ? 'wm_label';"
+                    "CREATE INDEX CONCURRENTLY labeled_jobs_on_jobs ON completed_job USING GIN ((result -> 'wm_labels')) WHERE result ? 'wm_label'"
                 ).execute(&mut *self.inner).await?;
             }
             let r = self.inner.apply(migration).await;
@@ -309,9 +309,6 @@ macro_rules! run_windmill_migration {
                     .await?;
                 tx.commit().await?;
                 tracing::info!("released lock for {migration_job_name}");
-
-
-                tracing::info!("Finished applying {migration_job_name} migration");
             } else {
                 tracing::info!("migration {migration_job_name} already done");
 
@@ -481,6 +478,16 @@ async fn fix_job_completed_index(db: &DB) -> Result<(), Error> {
             .await?;
     });
 
+    run_windmill_migration!("fix_labeled_jobs_index", &db, {
+        tracing::info!("Special migration to add index concurrently on job labels 2");
+        sqlx::query!("DROP INDEX CONCURRENTLY IF EXISTS labeled_jobs_on_jobs")
+            .execute(db)
+            .await?;
+        sqlx::query!(
+        "CREATE INDEX CONCURRENTLY labeled_jobs_on_jobs ON completed_job USING GIN ((result -> 'wm_labels')) WHERE result ? 'wm_label'"
+        ).execute(db).await?;
+    });
+
     Ok(())
 }
 

diff --git a/backend/windmill-api/src/jobs.rs b/backend/windmill-api/src/jobs.rs
@@ -4664,6 +4664,13 @@ pub fn filter_list_completed_query(
             .on_eq("id", "outstanding_wait_time.job_id");
     }
 
+    if let Some(label) = &lq.label {
+        let mut wh = format!("result->'wm_labels' ? ");
+        wh.push_str(&format!("'{}'", &label.replace("'", "''")));
+        sqlb.and_where("result ? 'wm_labels'");
+        sqlb.and_where(&wh);
+    }
+
     if w_id != "admins" || !lq.all_workspaces.is_some_and(|x| x) {
         sqlb.and_where_eq("workspace_id", "?".bind(&w_id));
     }
@@ -4752,13 +4759,6 @@ pub fn filter_list_completed_query(
         sqlb.and_where("result @> ?".bind(&result.replace("'", "''")));
     }
 
-    if let Some(label) = &lq.label {
-        let mut wh = format!("result->'wm_labels' ? ");
-        wh.push_str(&format!("'{}'", &label.replace("'", "''")));
-        sqlb.and_where(&wh);
-        sqlb.and_where("result ? 'wm_labels'");
-    }
-
     if lq.is_not_schedule.unwrap_or(false) {
         sqlb.and_where("schedule_path IS null");
     }

diff --git a/frontend/src/lib/components/common/button/Button.svelte b/frontend/src/lib/components/common/button/Button.svelte
@@ -152,6 +152,7 @@
 	)
 
 	const iconMap = {
+		xs3: 12,
 		xs2: 14,
 		xs: 14,
 		sm: 16,
@@ -161,6 +162,7 @@
 	}
 
 	const iconOnlyPadding = {
+		xs3: 'm-[0.5px] qhd:m-[1px]',
 		xs2: 'm-[1px] qhd:m-[1.125px]',
 		xs: 'm-[1px] qhd:m-[1.125px]',
 		sm: 'm-[2px] qhd:m-[2.25px]',
@@ -169,12 +171,9 @@
 		xl: 'm-[5px] qhd:m-[5.625px]'
 	}
 
-	let innerWidth = 0
-	$: lucideIconSize = (iconMap[size] ?? 12) * (innerWidth > 2500 ? 1.125 : 1)
+	$: lucideIconSize = (iconMap[size] ?? 12) * 1
 </script>
 
-<svelte:window bind:innerWidth />
-
 <div
 	class="{dropdownItems && dropdownItems.length > 0 && variant === 'contained'
 		? colorVariants[color].divider

diff --git a/frontend/src/lib/components/common/button/model.ts b/frontend/src/lib/components/common/button/model.ts
@@ -1,7 +1,7 @@
 export const BUTTON_COLORS = ['blue', 'red', 'dark', 'light', 'green', 'gray', 'none'] as const
 
 export namespace ButtonType {
-	export type Size = 'xs2' | 'xs' | 'sm' | 'md' | 'lg' | 'xl'
+	export type Size = 'xs3' | 'xs2' | 'xs' | 'sm' | 'md' | 'lg' | 'xl'
 	export type Color = string
 	export type Variant = 'contained' | 'border' | 'divider'
 	export type Target = '_self' | '_blank'
@@ -13,6 +13,7 @@ export namespace ButtonType {
 	}
 
 	export const FontSizeClasses: Record<ButtonType.Size, string> = {
+		xs3: 'text-2xs',
 		xs2: 'text-xs',
 		xs: 'text-xs',
 		sm: 'text-sm',
@@ -22,6 +23,11 @@ export namespace ButtonType {
 	} as const
 
 	export const SpacingClasses: Record<ButtonType.Size, Record<ButtonType.Variant, string>> = {
+		xs3: {
+			border: 'px-0.5 py-[1px] !rounded-xs',
+			contained: 'px-0.5 py-[1px]',
+			divider: ''
+		},
 		xs2: {
 			border: 'px-2 py-[4px]',
 			contained: 'px-2 py-[4px]',

diff --git a/frontend/src/lib/components/runs/RunRow.svelte b/frontend/src/lib/components/runs/RunRow.svelte
@@ -212,14 +212,14 @@
 		{/if}
 	</div>
 	{#if containsLabel}
-		<div class="w-3/12 flex justify-start">
+		<div class="w-3/12 flex justify-start px-0.5">
 			{#if job && job?.['labels']}
 				<div class="flex flex-row items-center gap-1 overflow-x-auto">
 					{#if Array.isArray(job?.['labels'])}
 						{#each job?.['labels'] as label}
 							<Button
 								variant="border"
-								size="xs2"
+								size="xs3"
 								btnClasses={twMerge(
 									activeLabel == label ? 'bg-blue-50 dark:bg-blue-900/50' : '',
 									'!text-2xs !font-normal truncate max-w-28'
@@ -228,9 +228,9 @@
 								on:click={() => {
 									dispatch('filterByLabel', label)
 								}}
+								endIcon={{ icon: ListFilter }}
 							>
 								{label}
-								<ListFilter size={10} />
 							</Button>
 						{/each}
 					{/if}
@@ -248,7 +248,7 @@
 					btnClasses="font-normal"
 					on:click={() => scheduleEditor?.openEdit(job.schedule_path ?? '', job.job_kind == 'flow')}
 				>
-					<div class="truncate text-ellipsis text-left">
+					<div class="truncate text-ellipsis text-left" title={job.schedule_path}>
 						{truncateRev(job.schedule_path, 20)}
 					</div>
 				</Button>
@@ -264,15 +264,15 @@
 			</div>
 		{:else}
 			<div class="flex flex-row gap-1 items-center">
-				<div class="text-xs">
-					{job.created_by}
+				<div class="text-xs truncate text-ellipsis text-left" title={job.created_by}>
+					{truncateRev(job.created_by ?? '', 20)}
 				</div>
 				{#if !isExternal}
 					<Button
 						size="xs2"
 						color="light"
 						on:click={() => {
-							dispatch('filterByUser', job.created_by)
+							dispatch('filterByUser', job.created_by ?? '')
 						}}
 					>
 						<ListFilter size={10} />

diff --git a/frontend/src/lib/components/sidebar/WorkspaceMenu.svelte b/frontend/src/lib/components/sidebar/WorkspaceMenu.svelte
@@ -39,6 +39,10 @@
 
 		if (!isOnEditPage) {
 			switchWorkspace(id)
+			if ($page.url.searchParams.get('workspace')) {
+				$page.url.searchParams.set('workspace', id)
+			}
+			goto($page.url.toString())
 		} else {
 			await goto('/')
 			switchWorkspace(id)

diff --git a/frontend/src/routes/(root)/(logged)/run/[...run]/+page.svelte b/frontend/src/routes/(root)/(logged)/run/[...run]/+page.svelte
@@ -333,7 +333,7 @@
 	<PersistentScriptDrawer bind:this={persistentScriptDrawer} />
 </Portal>
 
-{#if notfound}
+{#if notfound || (job?.workspace_id != undefined && $workspaceStore != undefined && job?.workspace_id != $workspaceStore)}
 	<div class="max-w-7xl px-4 mx-auto w-full">
 		<div class="flex flex-col gap-6">
 			<h1 class="text-red-400 mt-6">Job {$page.params.run} not found in {$workspaceStore}</h1>