From c7dc261f3d276b4b4f1f637ace6be14064900322 Mon Sep 17 00:00:00 2001 From: tuanna Date: Tue, 14 Jan 2025 18:05:36 +0700 Subject: [PATCH] Add isUpdateFilter property to NodeData --- studio/app/common/core/workflow/workflow.py | 1 + studio/app/common/core/workflow/workflow_runner.py | 5 +++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/studio/app/common/core/workflow/workflow.py b/studio/app/common/core/workflow/workflow.py index 3ec9aabb6..3a499a4c6 100644 --- a/studio/app/common/core/workflow/workflow.py +++ b/studio/app/common/core/workflow/workflow.py @@ -184,6 +184,7 @@ class NodeData: fileType: str = None hdf5Path: str = None matPath: str = None + isUpdateFilter: Optional[bool] = None dataFilterParam: Union[DataFilterParam, dict, None] = field( default_factory=lambda: DataFilterParam(dim1=[], roi=[]) ) diff --git a/studio/app/common/core/workflow/workflow_runner.py b/studio/app/common/core/workflow/workflow_runner.py index b73a82777..6b7fb9ebc 100644 --- a/studio/app/common/core/workflow/workflow_runner.py +++ b/studio/app/common/core/workflow/workflow_runner.py @@ -163,7 +163,7 @@ def _check_data_filter(cls, workspace_id, uid, node_id): ) exp_config = ExptConfigReader.read(expt_filepath) - assert exp_config.success == "success" + # assert exp_config.success == "success" assert exp_config.function[node_id].success == "success" @classmethod @@ -172,7 +172,6 @@ def filter_node_data(cls, workspace_id, uid, node_id, params): workflow_config = cls.get_workflow_config(workspace_id, uid, node_id) node = workflow_config.nodeDict[node_id] - node.data.dataFilterParam = params pkl_filepath = join_filepath( [ @@ -219,6 +218,8 @@ def filter_node_data(cls, workspace_id, uid, node_id, params): cls._save_json(original_output_info, node_dirpath) # write config + node.data.dataFilterParam = params + node.data.isUpdateFilter = True WorkflowConfigWriter( workspace_id, uid,