diff --git a/benchmarks/main.ts b/benchmarks/main.ts index 1109afde79..69d4156a12 100644 --- a/benchmarks/main.ts +++ b/benchmarks/main.ts @@ -269,14 +269,19 @@ await new Command() const updateState = setInterval(async () => { const elapsed = start ? Math.ceil((Date.now() - start) / 1000) : 0; const sum = jobsSent.reduce((a, b) => a + b, 0); - const queue_length = ( - await ( - await fetch( - host + "/api/w/" + config.workspace_id + "/jobs/queue/count", - { headers: { ["Authorization"]: "Bearer " + config.token } } - ) - ).json() - ).database_length; + const queue_length = -1; + try { + ( + await ( + await fetch( + host + "/api/w/" + config.workspace_id + "/jobs/queue/count", + { headers: { ["Authorization"]: "Bearer " + config.token } } + ) + ).json() + ).database_length; + } catch (e) { + console.error("Error reading queue count: " + e); + } await Deno.stdout.write( enc( `elapsed: ${elapsed}/${seconds} | jobs sent: ${JSON.stringify( diff --git a/frontend/src/lib/components/flows/FlowProgressBar.svelte b/frontend/src/lib/components/flows/FlowProgressBar.svelte index 627f18f727..1b8a657075 100644 --- a/frontend/src/lib/components/flows/FlowProgressBar.svelte +++ b/frontend/src/lib/components/flows/FlowProgressBar.svelte @@ -1,10 +1,14 @@ - + diff --git a/frontend/src/lib/components/progressBar/ProgressBar.svelte b/frontend/src/lib/components/progressBar/ProgressBar.svelte index 00e913d2bc..e814f53395 100644 --- a/frontend/src/lib/components/progressBar/ProgressBar.svelte +++ b/frontend/src/lib/components/progressBar/ProgressBar.svelte @@ -1,73 +1,49 @@
@@ -76,25 +52,37 @@ ? 'Error occured' : finished ? 'Done' - : `Step ${stepIndex + 1}${subStepIndex !== undefined ? `.${subStepIndex + 1}` : ''}`} + : `Step ${index + 1}${subIndex !== undefined ? `.${subIndex + 1}` : ''}`} - {state.length ? $percent.toFixed(0) : 0}% + {$percent.toFixed(0)}%
+
- {#each state as step, index} -
- {#if isLoopState(step)} - - {:else} - + {#each new Array(length) as _, partIndex (partIndex)} +
+ {#if partIndex < index - 1} +
+ {:else if partIndex == index - 1 || (partIndex == index && subIndex !== undefined)} +
{/if}
{/each} diff --git a/frontend/src/lib/components/progressBar/ProgressBarGeneralPart.svelte b/frontend/src/lib/components/progressBar/ProgressBarGeneralPart.svelte deleted file mode 100644 index ba35677ecf..0000000000 --- a/frontend/src/lib/components/progressBar/ProgressBarGeneralPart.svelte +++ /dev/null @@ -1,25 +0,0 @@ - - -
diff --git a/frontend/src/lib/components/progressBar/ProgressBarLoopAccessor.svelte b/frontend/src/lib/components/progressBar/ProgressBarLoopAccessor.svelte deleted file mode 100644 index dce506c671..0000000000 --- a/frontend/src/lib/components/progressBar/ProgressBarLoopAccessor.svelte +++ /dev/null @@ -1,20 +0,0 @@ - - -
diff --git a/frontend/src/lib/components/progressBar/ProgressBarLoopPart.svelte b/frontend/src/lib/components/progressBar/ProgressBarLoopPart.svelte deleted file mode 100644 index 96354e54ed..0000000000 --- a/frontend/src/lib/components/progressBar/ProgressBarLoopPart.svelte +++ /dev/null @@ -1,37 +0,0 @@ - - -{#each progresses as progress, i} - -{/each} diff --git a/frontend/src/lib/components/progressBar/index.ts b/frontend/src/lib/components/progressBar/index.ts deleted file mode 100644 index e32b648116..0000000000 --- a/frontend/src/lib/components/progressBar/index.ts +++ /dev/null @@ -1,3 +0,0 @@ -export { default as ProgressBar } from './ProgressBar.svelte' - -export * from './model' diff --git a/frontend/src/lib/components/progressBar/model.ts b/frontend/src/lib/components/progressBar/model.ts deleted file mode 100644 index 2815943daa..0000000000 --- a/frontend/src/lib/components/progressBar/model.ts +++ /dev/null @@ -1,45 +0,0 @@ -import { tweened } from 'svelte/motion' -import { cubicOut } from 'svelte/easing' - -export interface ProgressStateStoreValue { - length: number - index: number - finished: boolean - error: boolean -} - -export type StepKind = 'general' | 'loop' - -type Step = { - type: T - isDone: boolean -} - -export type GeneralStep = Step<'general'> -export type LoopStep = Step<'loop'> & { index: number; length: number } -export type ProgressStep = GeneralStep | LoopStep - -export function isLoopStep(step: ProgressStep | undefined): step is LoopStep { - return step?.type === 'loop' -} - -type State = { - type: T - isDone: boolean - isDoneChanged: boolean -} - -export type GeneralState = State<'general'> -export type LoopState = LoopStep & { index: number; indexChanged: boolean } -export type ProgressState = GeneralState | LoopState - -export function isLoopState(state: ProgressState | undefined): state is LoopState { - return state?.type === 'loop' -} - -export function getTween(initialValue = 0, duration = 200) { - return tweened(initialValue, { - duration, - easing: cubicOut - }) -} diff --git a/frontend/src/routes/(root)/+layout.svelte b/frontend/src/routes/(root)/+layout.svelte index 7a5aff5871..fac027b96c 100644 --- a/frontend/src/routes/(root)/+layout.svelte +++ b/frontend/src/routes/(root)/+layout.svelte @@ -25,7 +25,8 @@ 'Canceled', 'Missing service editorService', 'Unexpected usage', - 'NetworkError when attempting to fetch resource.' + 'NetworkError when attempting to fetch resource.', + "Client got disposed and can't be restarted." ] async function setUserWorkspaceStore() { @@ -162,7 +163,8 @@ interval && clearInterval(interval) }) - const darkMode = window.localStorage.getItem('dark-mode') ?? + const darkMode = + window.localStorage.getItem('dark-mode') ?? (window.matchMedia('(prefers-color-scheme: dark)').matches ? 'dark' : 'light') if (darkMode === 'dark') {