diff options
| author | Matthias Baumgartner <dev@igsor.net> | 2022-12-18 13:37:59 +0100 |
|---|---|---|
| committer | Matthias Baumgartner <dev@igsor.net> | 2022-12-18 13:37:59 +0100 |
| commit | 057e09d6537bf5c39815661a75819081e3e5fda7 (patch) | |
| tree | 0a59bbfe1c44d3497daad9f25ff9e7eb2bf9eb82 /bsie/tools/pipeline.py | |
| parent | 5850ff2bcb1052883cf301590126609b0657fbc9 (diff) | |
| download | bsie-057e09d6537bf5c39815661a75819081e3e5fda7.tar.gz bsie-057e09d6537bf5c39815661a75819081e3e5fda7.tar.bz2 bsie-057e09d6537bf5c39815661a75819081e3e5fda7.zip | |
adaptions to updates in bsfs
Diffstat (limited to 'bsie/tools/pipeline.py')
| -rw-r--r-- | bsie/tools/pipeline.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/bsie/tools/pipeline.py b/bsie/tools/pipeline.py index 52ce526..20e8ddf 100644 --- a/bsie/tools/pipeline.py +++ b/bsie/tools/pipeline.py @@ -18,6 +18,9 @@ __all__: typing.Sequence[str] = ( 'Pipeline', ) +# constants +FILE_PREFIX = 'file#' + ## code ## logger = logging.getLogger(__name__) @@ -48,7 +51,7 @@ class Pipeline(): ext2rdr: typing.Dict[base.extractor.Extractor, typing.Optional[base.reader.Reader]] ): # store core members - self._prefix = prefix + self._prefix = prefix + FILE_PREFIX self._ext2rdr = ext2rdr # compile schema from all extractors self._schema = bsfs.schema.Schema.Union(ext.schema for ext in ext2rdr) @@ -114,7 +117,7 @@ class Pipeline(): # create subject for file uuid = bsfs.uuid.UCID.from_path(path) - subject = node.Node(ns.bsfs.File, self._prefix + 'file#' + uuid) + subject = node.Node(ns.bsfs.File, self._prefix[uuid]) # extract information for rdr, extrs in rdr2ext.items(): |