|
2 | 2 | import { page } from '$app/stores'; |
3 | 3 | import JSchema from '$lib/components/v2/workflow/JSchema.svelte'; |
4 | 4 | import { displayStandardErrorAlert } from '$lib/common/errors'; |
5 | | - import FormBuilder from './FormBuilder.svelte'; |
6 | 5 | import ImportExportArgs from './ImportExportArgs.svelte'; |
7 | 6 | import { |
8 | 7 | stripNullAndEmptyObjectsAndArrays, |
9 | 8 | stripSchemaProperties |
10 | 9 | } from '$lib/components/common/jschema/schema_management'; |
| 10 | + import FormBuilder from './FormBuilder.svelte'; |
11 | 11 |
|
12 | 12 | const SUPPORTED_SCHEMA_VERSIONS = ['pydantic_v1']; |
13 | 13 |
|
|
22 | 22 | let parallelSchemaComponent; |
23 | 23 | let unsavedChangesParallel = false; |
24 | 24 | let unsavedChangesNonParallel = false; |
| 25 | +
|
| 26 | + /** @type {FormBuilder|undefined} */ |
| 27 | + let nonParallelFormBuilderComponent; |
| 28 | + /** @type {FormBuilder|undefined} */ |
| 29 | + let parallelFormBuilderComponent; |
| 30 | + let unsavedChangesFormBuilderParallel = false; |
| 31 | + let unsavedChangesFormBuilderNonParallel = false; |
| 32 | +
|
25 | 33 | let savingChanges = false; |
26 | 34 |
|
27 | | - $: unsavedChanges = unsavedChangesParallel || unsavedChangesNonParallel; |
| 35 | + $: unsavedChanges = |
| 36 | + unsavedChangesParallel || |
| 37 | + unsavedChangesNonParallel || |
| 38 | + unsavedChangesFormBuilderParallel || |
| 39 | + unsavedChangesFormBuilderNonParallel; |
28 | 40 |
|
29 | 41 | $: isSchemaValid = argsSchemaVersionValid( |
30 | 42 | workflowTask.is_legacy_task |
|
36 | 48 | workflowTask.task_type === 'non_parallel' || workflowTask.task_type === 'compound'; |
37 | 49 | $: hasParallel = workflowTask.task_type === 'parallel' || workflowTask.task_type === 'compound'; |
38 | 50 |
|
| 51 | + $: argsSchemaNonParallel = workflowTask.is_legacy_task |
| 52 | + ? null |
| 53 | + : workflowTask.task.args_schema_non_parallel; |
| 54 | +
|
39 | 55 | $: argsSchemaParallel = workflowTask.is_legacy_task |
40 | 56 | ? workflowTask.task_legacy.args_schema |
41 | 57 | : workflowTask.task.args_schema_parallel; |
|
49 | 65 | nonParallelSchemaComponent?.validateArguments(); |
50 | 66 | parallelSchemaComponent?.validateArguments(); |
51 | 67 | } catch (err) { |
52 | | - console.log(err); |
53 | | - displayStandardErrorAlert(err, 'json-schema-validation-errors'); |
| 68 | + console.error(err); |
| 69 | + displayStandardErrorAlert(err, 'task-args-validation-errors'); |
| 70 | + return; |
| 71 | + } |
| 72 | + const invalidFormBuilderNonParallel = |
| 73 | + nonParallelFormBuilderComponent && !nonParallelFormBuilderComponent.validateArguments(); |
| 74 | + const invalidFormBuilderParallel = |
| 75 | + parallelFormBuilderComponent && !parallelFormBuilderComponent.validateArguments(); |
| 76 | + if (invalidFormBuilderNonParallel || invalidFormBuilderParallel) { |
54 | 77 | return; |
55 | 78 | } |
56 | 79 | const payload = {}; |
57 | 80 | if (hasNonParallel) { |
58 | | - payload.args_non_parallel = nonParallelSchemaComponent?.getArguments(); |
| 81 | + if (nonParallelSchemaComponent) { |
| 82 | + payload.args_non_parallel = nonParallelSchemaComponent.getArguments(); |
| 83 | + } else if (nonParallelFormBuilderComponent) { |
| 84 | + payload.args_non_parallel = nonParallelFormBuilderComponent.getArguments(); |
| 85 | + } |
59 | 86 | } |
60 | 87 | if (hasParallel) { |
61 | | - payload.args_parallel = parallelSchemaComponent?.getArguments(); |
| 88 | + if (parallelSchemaComponent) { |
| 89 | + payload.args_parallel = parallelSchemaComponent.getArguments(); |
| 90 | + } else if (parallelFormBuilderComponent) { |
| 91 | + payload.args_parallel = parallelFormBuilderComponent.getArguments(); |
| 92 | + } |
62 | 93 | } |
63 | 94 | await handleSaveChanges(payload); |
64 | 95 | } |
65 | 96 |
|
66 | 97 | export function discardChanges() { |
67 | 98 | nonParallelSchemaComponent?.discardChanges(workflowTask.args_non_parallel); |
68 | 99 | parallelSchemaComponent?.discardChanges(workflowTask.args_parallel); |
69 | | - } |
70 | | -
|
71 | | - /** |
72 | | - * @param {object} updatedEntry |
73 | | - */ |
74 | | - async function saveGenericFormEntryNonParallel(updatedEntry) { |
75 | | - await handleSaveChanges({ args_non_parallel: updatedEntry }); |
76 | | - } |
77 | | -
|
78 | | - /** |
79 | | - * @param {object} updatedEntry |
80 | | - */ |
81 | | - async function saveGenericFormEntryParallel(updatedEntry) { |
82 | | - await handleSaveChanges({ args_parallel: updatedEntry }); |
| 100 | + nonParallelFormBuilderComponent?.discardChanges(workflowTask.args_non_parallel); |
| 101 | + parallelFormBuilderComponent?.discardChanges(workflowTask.args_parallel); |
83 | 102 | } |
84 | 103 |
|
85 | 104 | /** |
|
121 | 140 | } |
122 | 141 | onWorkflowTaskUpdated(result); |
123 | 142 | } else { |
124 | | - displayStandardErrorAlert(await result, 'json-schema-validation-errors'); |
| 143 | + displayStandardErrorAlert(await result, 'task-args-validation-errors'); |
125 | 144 | } |
126 | 145 | savingChanges = false; |
127 | 146 | } |
|
159 | 178 | </script> |
160 | 179 |
|
161 | 180 | <div id="workflow-arguments-schema-panel"> |
162 | | - <div id="json-schema-validation-errors" /> |
| 181 | + <div id="task-args-validation-errors" /> |
163 | 182 | {#if workflowTask.task_type === 'non_parallel' || workflowTask.task_type === 'compound'} |
164 | | - {#if hasNonParallelArgs && hasParallelArgs} |
165 | | - <h5 class="ps-2 mt-3">Initialisation Parameters</h5> |
| 183 | + {#if (hasNonParallelArgs && hasParallelArgs) || (workflowTask.task_type === 'compound' && !workflowTask.is_legacy_task && !workflowTask.task.args_schema_non_parallel)} |
| 184 | + <h5 class="ps-2 mt-3">Initialisation Arguments</h5> |
166 | 185 | {/if} |
167 | 186 | {#if !workflowTask.is_legacy_task && workflowTask.task.args_schema_non_parallel && isSchemaValid} |
168 | 187 | <div class="args-list"> |
|
176 | 195 | </div> |
177 | 196 | {:else} |
178 | 197 | <div> |
179 | | - <span id="argsPropertiesFormError" /> |
180 | 198 | <FormBuilder |
181 | | - entry={workflowTask.args_non_parallel} |
182 | | - updateEntry={saveGenericFormEntryNonParallel} |
| 199 | + args={workflowTask.args_non_parallel} |
| 200 | + bind:this={nonParallelFormBuilderComponent} |
| 201 | + bind:unsavedChanges={unsavedChangesFormBuilderNonParallel} |
183 | 202 | /> |
184 | 203 | </div> |
185 | 204 | {/if} |
186 | 205 | {/if} |
187 | | - {#if hasNonParallelArgs && hasParallelArgs} |
| 206 | + {#if (hasNonParallelArgs && hasParallelArgs) || (workflowTask.task_type === 'compound' && !argsSchemaParallel && !workflowTask.is_legacy_task && !workflowTask.task.args_schema_non_parallel)} |
188 | 207 | <hr /> |
189 | 208 | {/if} |
190 | 209 | {#if workflowTask.task_type === 'parallel' || workflowTask.task_type === 'compound'} |
191 | | - {#if hasParallelArgs && hasNonParallelArgs} |
192 | | - <h5 class="ps-2 mt-3">Compute Parameters</h5> |
| 210 | + {#if (hasParallelArgs && hasNonParallelArgs) || (workflowTask.task_type === 'compound' && !argsSchemaParallel)} |
| 211 | + <h5 class="ps-2 mt-3">Compute Arguments</h5> |
193 | 212 | {/if} |
194 | 213 | {#if argsSchemaParallel && isSchemaValid} |
195 | 214 | <div class="args-list"> |
|
203 | 222 | </div> |
204 | 223 | {:else} |
205 | 224 | <div class="mb-3"> |
206 | | - <span id="argsPropertiesFormError" /> |
207 | 225 | <FormBuilder |
208 | | - entry={workflowTask.args_parallel} |
209 | | - updateEntry={saveGenericFormEntryParallel} |
| 226 | + args={workflowTask.args_parallel} |
| 227 | + bind:this={parallelFormBuilderComponent} |
| 228 | + bind:unsavedChanges={unsavedChangesFormBuilderParallel} |
210 | 229 | /> |
211 | 230 | </div> |
212 | 231 | {/if} |
213 | 232 | {/if} |
214 | | - {#if !hasNonParallelArgs && !hasParallelArgs} |
| 233 | + {#if !hasNonParallelArgs && !hasParallelArgs && (argsSchemaParallel || argsSchemaNonParallel)} |
215 | 234 | <p class="mt-3 ps-3">No arguments</p> |
216 | 235 | {/if} |
217 | 236 | <div class="d-flex jschema-controls-bar p-3"> |
|
220 | 239 | onImport={handleSaveChanges} |
221 | 240 | exportDisabled={unsavedChanges || savingChanges} |
222 | 241 | /> |
223 | | - {#if ((!workflowTask.is_legacy_task && workflowTask.task.args_schema_non_parallel) || argsSchemaParallel) && isSchemaValid} |
| 242 | + {#if isSchemaValid || nonParallelFormBuilderComponent || parallelFormBuilderComponent} |
224 | 243 | <div> |
225 | 244 | <button |
226 | 245 | class="btn btn-warning" |
|
0 commit comments