This is an automated email from the ASF dual-hosted git repository.

yunyd pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/main by this push:
     new aee6095b7e fix: Persist & apply “Data Transfer Batch Size” from 
Workflow Settings (#3770)
aee6095b7e is described below

commit aee6095b7e70ad9cbf2e9d206fb600a3421536be
Author: Meng Wang <[email protected]>
AuthorDate: Fri Sep 26 11:49:39 2025 -0700

    fix: Persist & apply “Data Transfer Batch Size” from Workflow Settings 
(#3770)
    
    Fixes: #3769
    
    Wire the settings form to update the workflow’s dataTransferBatchSize
    whenever the form is valid.
    
    How to test:
    1. Open any workflow → Settings → set Data Transfer Batch Size to 1.
    2. reload page → value remains 1.
    3. Run workflow → verify runtime uses 1 (logs).
    
    
    <img width="253" height="388" alt="Screenshot 2025-09-25 at 11 56 45 AM"
    
src="https://github.com/user-attachments/assets/3190117d-92d2-452a-8639-e1d8958ee807";
    />
    
    ---------
    
    Co-authored-by: yunyad <[email protected]>
---
 .../workspace/component/left-panel/settings/settings.component.ts   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/core/gui/src/app/workspace/component/left-panel/settings/settings.component.ts
 
b/core/gui/src/app/workspace/component/left-panel/settings/settings.component.ts
index 39547bda62..ead28857ff 100644
--- 
a/core/gui/src/app/workspace/component/left-panel/settings/settings.component.ts
+++ 
b/core/gui/src/app/workspace/component/left-panel/settings/settings.component.ts
@@ -55,6 +55,12 @@ export class SettingsComponent implements OnInit {
       dataTransferBatchSize: [this.currentDataTransferBatchSize, 
[Validators.required, Validators.min(1)]],
     });
 
+    this.settingsForm.valueChanges.pipe(untilDestroyed(this)).subscribe(value 
=> {
+      if (this.settingsForm.valid) {
+        this.confirmUpdateDataTransferBatchSize(value.dataTransferBatchSize);
+      }
+    });
+
     this.workflowActionService
       .workflowChanged()
       .pipe(untilDestroyed(this))

Reply via email to