aboutsummaryrefslogtreecommitdiffstats
path: root/bsie/tools/pipeline.py
diff options
context:
space:
mode:
authorMatthias Baumgartner <dev@igsor.net>2022-12-14 06:10:25 +0100
committerMatthias Baumgartner <dev@igsor.net>2022-12-14 06:10:25 +0100
commit559e643bb1fa39feefd2eb73847ad9420daf1deb (patch)
tree13243e2e25edd90d16789e6f6e4e473748f347a4 /bsie/tools/pipeline.py
parentedc747252a04675c46059215751719b6666a77f9 (diff)
downloadbsie-559e643bb1fa39feefd2eb73847ad9420daf1deb.tar.gz
bsie-559e643bb1fa39feefd2eb73847ad9420daf1deb.tar.bz2
bsie-559e643bb1fa39feefd2eb73847ad9420daf1deb.zip
bsie extraction and info apps
Diffstat (limited to 'bsie/tools/pipeline.py')
-rw-r--r--bsie/tools/pipeline.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/bsie/tools/pipeline.py b/bsie/tools/pipeline.py
index 8e1c992..da422c0 100644
--- a/bsie/tools/pipeline.py
+++ b/bsie/tools/pipeline.py
@@ -70,6 +70,10 @@ class Pipeline():
and self._prefix == other._prefix \
and self._ext2rdr == other._ext2rdr
+ def predicates(self) -> typing.Iterator[_schema.Predicate]:
+ """Return the predicates that are extracted from a file."""
+ return iter({pred for ext in self._ext2rdr for pred in ext.predicates()})
+
def __call__(
self,
path: URI,