adaptions to updates in bsfs

3 files changed, 11 insertions, 6 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():
diff --git a/bsie/utils/bsfs.py b/bsie/utils/bsfs.py
index c48049d..0b88479 100644
--- a/bsie/utils/bsfs.py
+++ b/bsie/utils/bsfs.py
@@ -9,6 +9,7 @@ import typing
 
 # bsfs imports
 from bsfs import Open, schema
+from bsfs.apps.init import init_sparql_store
 from bsfs.namespace import Namespace
 from bsfs.utils import URI, typename, uuid
 
@@ -17,6 +18,7 @@ __all__: typing.Sequence[str] = (
     'Namespace',
     'Open',
     'URI',
+    'init_sparql_store',
     'schema',
     'typename',
     'uuid',
diff --git a/bsie/utils/namespaces.py b/bsie/utils/namespaces.py
index d6e1c72..a29fc1b 100644
--- a/bsie/utils/namespaces.py
+++ b/bsie/utils/namespaces.py
@@ -11,10 +11,10 @@ import typing
 from . import bsfs as _bsfs
 
 # constants
-bse = _bsfs.Namespace('http://bsfs.ai/schema/Entity#')
-bsfs = _bsfs.Namespace('http://bsfs.ai/schema/')
-bsm = _bsfs.Namespace('http://bsfs.ai/schema/Meta#')
-xsd = _bsfs.Namespace('http://www.w3.org/2001/XMLSchema#')
+bse = _bsfs.Namespace('http://bsfs.ai/schema/Entity')
+bsfs = _bsfs.Namespace('http://bsfs.ai/schema', fsep='/')
+bsm = _bsfs.Namespace('http://bsfs.ai/schema/Meta')
+xsd = _bsfs.Namespace('http://www.w3.org/2001/XMLSchema')
 
 # export
 __all__: typing.Sequence[str] = (