Add isUpdateFilter property to NodeData

arayabrain · Jan 14, 2025 · c7dc261 · c7dc261
1 parent 5fbcd44
commit c7dc261
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git 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
@@ -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,