Merge pull request #1112 from dimagi/cs/passthrough_nodes

Make ExtractParticipantData node passthrough

apps/pipelines/nodes/nodes.py

@@ -485,7 +485,7 @@ def _process(self, input, state: PipelineState, node_id: str, **kwargs) -> Pipel
             new_reference_data = self.update_reference_data(output, reference_data)
 
         self.post_extraction_hook(new_reference_data, state)
-        output = json.dumps(new_reference_data)
+        output = input if self.is_passthrough else json.dumps(new_reference_data)
         return PipelineState.from_node_output(node_name=self.name, node_id=node_id, output=output)
 
     def post_extraction_hook(self, output, state):
@@ -598,6 +598,10 @@ class ExtractStructuredData(ExtractStructuredDataNodeMixin, LLMResponse, Structu
         json_schema_extra=UiSchema(widget=Widgets.expandable_text),
     )
 
+    @property
+    def is_passthrough(self) -> bool:
+        return False
+
 
 class ExtractParticipantData(ExtractStructuredDataNodeMixin, LLMResponse, StructuredDataSchemaValidatorMixin):
     """Extract structured data and saves it as participant data"""
@@ -616,6 +620,10 @@ class ExtractParticipantData(ExtractStructuredDataNodeMixin, LLMResponse, Struct
     )
     key_name: str = ""
 
+    @property
+    def is_passthrough(self) -> bool:
+        return True
+
     def get_reference_data(self, state) -> dict:
         """Returns the participant data as reference. If there is a `key_name`, the value in the participant data
         corresponding to that key will be returned insteadg