starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-08-24 16:01:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

app db

Browse Source
This commit is contained in:
Ruben Fiszel
2025-07-18 22:18:47 +00:00
parent 1e608c785b
commit 79cb7547b1
7 changed files with 35 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/handle_child.rs
-1
View File
@@ -459,7 +459,6 @@ pub async fn write_lines(
let w_id = w_id.to_string();
let job_id = job_id.clone();
let pg_log_total_size = pg_log_total_size.clone();
(do_write, write_result) = tokio::spawn(async move {
append_job_logs(
&job_id,
frontend/src/lib/components/HistoricInputs.svelte
+2 -2
View File
@@ -3,7 +3,7 @@
import { sendUserToast } from '$lib/utils.js'
import RunningJobSchemaPicker from '$lib/components/schema/RunningJobSchemaPicker.svelte'
import { createEventDispatcher, onDestroy } from 'svelte'
import JobLoader from './runs/JobLoader.svelte'
import JobsLoader from './runs/JobsLoader.svelte'
import { DataTable } from '$lib/components/table'
import HistoricList from './HistoricList.svelte'
import { Loader2 } from 'lucide-svelte'
@@ -100,7 +100,7 @@
<svelte:window onkeydown={handleKeydown} />
{#if runnableId}
<JobLoader
<JobsLoader
bind:jobs
path={runnableId}
isSkipped={false}
frontend/src/lib/components/SavedInputs.svelte
+2 -2
View File
@@ -17,7 +17,7 @@
import Toggle from './Toggle.svelte'
import Tooltip from './Tooltip.svelte'
import TimeAgo from './TimeAgo.svelte'
import JobLoader from './runs/JobLoader.svelte'
import JobsLoader from './runs/JobsLoader.svelte'
import Skeleton from './common/skeleton/Skeleton.svelte'
import SaveInputsButton from './SaveInputsButton.svelte'
@@ -144,7 +144,7 @@
</script>
{#if runnableId}
<JobLoader
<JobsLoader
bind:jobs
path={runnableId}
isSkipped={false}
frontend/src/lib/components/apps/components/display/dbtable/AppDbExplorer.svelte
+3 -3
View File
@@ -274,7 +274,7 @@
}
runnableComponent?.runComponent(undefined, undefined, undefined, currentParams, {
done: (items) => {
onDone: (items) => {
let lastRow = -1
if (datasource?.rowCount && datasource.rowCount <= params.endRow) {
@@ -306,10 +306,10 @@
params.failCallback()
}
},
cancel: () => {
onCancel: () => {
params.failCallback()
},
error: () => {
onError: (error) => {
params.failCallback()
}
})
frontend/src/lib/components/apps/components/helpers/RunnableComponent.svelte
+4 -2
View File
@@ -549,7 +549,8 @@
noToast = true,
inlineScriptOverride?: InlineScript,
setRunnableJobEditorPanel?: boolean,
dynamicArgsOverride?: Record<string, any>
dynamicArgsOverride?: Record<string, any>,
callbacks?: RunnableCallback
): Promise<string | undefined> {
try {
if (cancellableRun && !dynamicArgsOverride) {
@@ -560,7 +561,8 @@
noToast,
inlineScriptOverride,
setRunnableJobEditorPanel,
dynamicArgsOverride
dynamicArgsOverride,
callbacks
)
}
} catch (e) {
frontend/src/lib/components/runs/JobLoader.svelte → frontend/src/lib/components/runs/JobsLoader.svelte
View File
frontend/src/routes/(root)/(logged)/runs/[...path]/+page.svelte
+24 -24
View File
@@ -31,7 +31,7 @@
import RunsQueue from '$lib/components/runs/RunsQueue.svelte'
import { twMerge } from 'tailwind-merge'
import ManuelDatePicker from '$lib/components/runs/ManuelDatePicker.svelte'
import JobLoader from '$lib/components/runs/JobLoader.svelte'
import JobsLoader from '$lib/components/runs/JobsLoader.svelte'
import { AlertTriangle, Calendar, ChevronDown, Clock } from 'lucide-svelte'
import ConcurrentJobsChart from '$lib/components/ConcurrentJobsChart.svelte'
import ToggleButtonGroup from '$lib/components/common/toggleButton-v2/ToggleButtonGroup.svelte'
@@ -198,7 +198,7 @@
}
let innerWidth = $state(window.innerWidth)
let jobLoader: JobLoader | undefined = $state(undefined)
let jobsLoader: JobsLoader | undefined = $state(undefined)
let externalJobs: Job[] | undefined = $state(undefined)
let graph: 'RunChart' | 'ConcurrencyChart' = $state(
@@ -342,7 +342,7 @@
if (resultError == '' && argError == '') {
filterTimeout && clearTimeout(filterTimeout)
filterTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 2000)
}
}
@@ -359,7 +359,7 @@
batchReRunOptions = { flow: {}, script: {} }
selectionMode = false
selectedWorkspace = undefined
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}
async function loadUsernames(): Promise<void> {
@@ -548,7 +548,7 @@
requestBody: uuidsToCancel
})
selectedIds = []
jobLoader?.loadJobs(minTs, maxTs, true, true)
jobsLoader?.loadJobs(minTs, maxTs, true, true)
sendUserToast(`Canceled ${uuids.length} jobs`)
selectionMode = false
}
@@ -653,7 +653,7 @@
selectedIds = []
batchReRunOptions = { flow: {}, script: {} }
jobLoader?.loadJobs(minTs, maxTs, true, true)
jobsLoader?.loadJobs(minTs, maxTs, true, true)
selectionMode = false
}
@@ -689,8 +689,8 @@
}
async function loadExtra() {
if (jobLoader) {
lastFetchWentToEnd = await jobLoader.loadExtraJobs()
if (jobsLoader) {
lastFetchWentToEnd = await jobsLoader.loadExtraJobs()
console.log(lastFetchWentToEnd)
}
}
@@ -772,7 +772,7 @@
})
</script>
<JobLoader
<JobsLoader
{allowWildcards}
{allWorkspaces}
bind:jobs
@@ -804,7 +804,7 @@
{resultError}
{tag}
bind:loading
bind:this={jobLoader}
bind:this={jobsLoader}
lookback={graphIsRunsChart ? 0 : lookback}
/>
@@ -982,7 +982,7 @@
minTs = e.detail.min.toISOString()
maxTs = e.detail.max.toISOString()
manualDatePicker?.resetChoice()
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}}
on:pointClicked={(e) => {
runsTable?.scrollToRun(e.detail)
@@ -997,7 +997,7 @@
on:zoom={async (e) => {
minTs = e.detail.min.toISOString()
maxTs = e.detail.max.toISOString()
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}}
/>
{/if}
@@ -1071,14 +1071,14 @@
minTs = new Date(detail).toISOString()
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
on:clear={async () => {
minTs = undefined
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
/>
@@ -1100,14 +1100,14 @@
maxTs = new Date(detail).toISOString()
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
on:clear={async () => {
maxTs = undefined
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
/>
@@ -1119,7 +1119,7 @@
<ManuelDatePicker
on:loadJobs={() => {
lastFetchWentToEnd = false
jobLoader?.loadJobs(minTs, maxTs, true, true)
jobsLoader?.loadJobs(minTs, maxTs, true, true)
}}
bind:minTs
bind:maxTs
@@ -1311,7 +1311,7 @@
minTs = e.detail.min.toISOString()
maxTs = e.detail.max.toISOString()
manualDatePicker?.resetChoice()
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}}
on:pointClicked={(e) => {
runsTable?.scrollToRun(e.detail)
@@ -1326,7 +1326,7 @@
on:zoom={async (e) => {
minTs = e.detail.min.toISOString()
maxTs = e.detail.max.toISOString()
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}}
/>
{/if}
@@ -1405,14 +1405,14 @@
minTs = new Date(detail).toISOString()
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
on:clear={async () => {
minTs = undefined
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
/>
@@ -1435,14 +1435,14 @@
maxTs = new Date(detail).toISOString()
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
on:clear={async () => {
maxTs = undefined
calendarChangeTimeout && clearTimeout(calendarChangeTimeout)
calendarChangeTimeout = setTimeout(() => {
jobLoader?.loadJobs(minTs, maxTs, true)
jobsLoader?.loadJobs(minTs, maxTs, true)
}, 1000)
}}
/>
@@ -1454,7 +1454,7 @@
<ManuelDatePicker
on:loadJobs={() => {
lastFetchWentToEnd = false
jobLoader?.loadJobs(minTs, maxTs, true, true)
jobsLoader?.loadJobs(minTs, maxTs, true, true)
}}
bind:this={manualDatePicker}
bind:minTs