Add test to debug filter execution in ConditionalConnector

pier-digital · Sep 10, 2024 · 2a15de8 · 2a15de8
1 parent 9154187
commit 2a15de8
Show file tree

Hide file tree

Showing 5 changed files with 490 additions and 7 deletions.
diff --git a/retrack/engine/executor.py b/retrack/engine/executor.py
@@ -126,11 +126,6 @@ def __run_node(self, node_id: str, execution: Execution):
             node.model_dump(by_alias=True), current_node_filter, execution=execution
         )
 
-        if input_params is None or (
-            hasattr(input_params, "empty") and input_params.empty
-        ):
-            return
-
         # TODO: Remove this condition after adding support for kwargs in the run method for all nodes
         if node.kind() == NodeKind.CONNECTOR:
             input_params["context"] = execution.context

diff --git a/retrack/engine/rule.py b/retrack/engine/rule.py
@@ -38,7 +38,7 @@ def create(
         dynamic_nodes_registry: Registry,
         validator_registry: Registry = validators.registry(),
         raise_if_null_version: bool = False,
-        validate_version: bool = True,
+        validate_version: bool = False,
         name: str = None,
     ):
         components_registry = Rule.create_component_registry(

diff --git a/retrack/nodes/dynamic/conditional_connector.py b/retrack/nodes/dynamic/conditional_connector.py
@@ -29,7 +29,7 @@ def conditional_connector_factory(
         input_fields[name] = BaseDynamicNode.create_sub_field(InputConnectionModel)
 
     inputs_model = BaseDynamicIOModel.with_fields(
-        "CSVTableV0InputsModel", **input_fields
+        "ConditionalConnectorInputsModel", **input_fields
     )
 
     models = {