diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs index a949ef917e..710cfedda2 100644 --- a/backend/windmill-queue/src/jobs.rs +++ b/backend/windmill-queue/src/jobs.rs @@ -2678,7 +2678,7 @@ fn restructure_cloudevents_metadata( let mut hm = serde_json::from_str::>>>(&str) .map_err(|e| Error::BadRequest(format!("invalid json: {}", e)))? .unwrap_or_else(HashMap::new); - hm.insert("WEBHOOK__METADATA__".to_string(), to_raw_value(&p)); + hm.insert("WEBHOOK__METADATA__".to_string(), to_raw_value(&p)); Ok(hm) } } @@ -2836,7 +2836,10 @@ where .unwrap() .starts_with("application/cloudevents-batch+json") { - Err(Error::BadRequest(format!("Cloud events batching is not supported yet")).into_response()) + Err( + Error::BadRequest(format!("Cloud events batching is not supported yet")) + .into_response(), + ) } else if content_type .unwrap() .starts_with("application/x-www-form-urlencoded") diff --git a/frontend/src/routes/(root)/(logged)/workers/+page.svelte b/frontend/src/routes/(root)/(logged)/workers/+page.svelte index 39ffcd2fee..dd231b6b46 100644 --- a/frontend/src/routes/(root)/(logged)/workers/+page.svelte +++ b/frontend/src/routes/(root)/(logged)/workers/+page.svelte @@ -20,6 +20,8 @@ import { displayDate, groupBy, pluralize, truncate } from '$lib/utils' import { AlertTriangle, FileJson, LineChart, Plus, Search } from 'lucide-svelte' import { onDestroy, onMount } from 'svelte' + import AutoComplete from 'simple-svelte-autocomplete' + import YAML from 'yaml' let workers: WorkerPing[] | undefined = undefined @@ -295,13 +297,13 @@ {/if}

Worker Groups

{groupWorkers?.length} Worker Groups Worker groups are groups of workers that share a config and are meant to be identical. Worker groups are meant to be used with tags. Tags can be assigned to scripts and flows and can be seen as dedicated queues. Only the corresponding -

{#if $superadmin} @@ -378,9 +380,20 @@ {/if}
- {#if Object.keys(workerGroups ?? {}).length > 5} -
-