Create a custom nodes to filter document score before passing it to other nodes.

[zh0613]

This is my filter
class FilterScore:
outgoing_edges = 1

@staticmethod
def run_batch(documents):
    filtered_documents = [doc for doc in documents if doc.score > 80]
    return filtered_documents

This is my nodes:
pipe = Pipeline()
pipe.add_node(component=retriever, name="retriever", inputs=["Query"])
pipe.add_node(component=FilterScore(), name="filter", inputs=["retriever"])
pipe.add_node(component=prompt_node, name="prompt_node", inputs=["filter"])

[anakin87]

Hello, @zh0613!

A similar node is already available as an integration: Haystack Threshold Node.

[zh0613]

@anakin87 Thank you so much