From d6a5c0f596a212f0e1d4e4b351b5b0e6857d74f7 Mon Sep 17 00:00:00 2001 From: Matthias Baumgartner Date: Wed, 26 Jul 2023 12:48:54 +0200 Subject: refactored naming policy into uri matcher --- bsie/lib/pipeline.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'bsie/lib/pipeline.py') diff --git a/bsie/lib/pipeline.py b/bsie/lib/pipeline.py index 30fd6fd..98d9cc8 100644 --- a/bsie/lib/pipeline.py +++ b/bsie/lib/pipeline.py @@ -6,8 +6,9 @@ import typing # bsie imports from bsie.extractor import Extractor +from bsie.matcher import nodes from bsie.reader import Reader -from bsie.utils import bsfs, errors, node, ns +from bsie.utils import bsfs, errors, ns # exports __all__: typing.Sequence[str] = ( @@ -85,7 +86,7 @@ class Pipeline(): self, path: bsfs.URI, principals: typing.Optional[typing.Iterable[bsfs.schema.Predicate]] = None, - ) -> typing.Iterator[typing.Tuple[node.Node, bsfs.schema.Predicate, typing.Any]]: + ) -> typing.Iterator[typing.Tuple[nodes.Node, bsfs.schema.Predicate, typing.Any]]: """Extract triples from the file at *path*. Optionally, limit triples to *principals*.""" # get principals principals = set(principals) if principals is not None else set(self.schema.predicates()) @@ -104,9 +105,7 @@ class Pipeline(): rdr2ext[rdr].add(ext) # create subject for file - subject = node.Node(ns.bsn.Entity, - ucid=bsfs.uuid.UCID.from_path(path), - ) + subject = nodes.Entity(ucid=bsfs.uuid.UCID.from_path(path)) # extract information for rdr, extrs in rdr2ext.items(): -- cgit v1.2.3