diff --git a/src/workflow/engine.py b/src/workflow/engine.py index 5650987..c595e08 100644 --- a/src/workflow/engine.py +++ b/src/workflow/engine.py @@ -88,6 +88,12 @@ class DefaultDataPresenter(DataPresenter): return Expando(data.to_dict(self.mappings)) +class DefaultDataFilter(DataFilter): + """Default data filter that returns True for all data items.""" + + def filter(self, data: Any) -> bool: + return True + class WorkflowEngine: """Orchestrates the data processing pipeline using generators."""