import fixes

1 files changed, 4 insertions, 5 deletions

diff --git a/test/tools/test_pipeline.py b/test/tools/test_pipeline.py
index 0dd8c75..92801ed 100644
--- a/test/tools/test_pipeline.py
+++ b/test/tools/test_pipeline.py
@@ -11,9 +11,8 @@ import unittest
 
 # bsie imports
 from bsie.base import errors
-from bsie.utils import ns
 from bsie.utils.bsfs import URI
-from bsie.utils.node import Node
+from bsie.utils import bsfs, node, ns
 import bsie.extractor.generic.constant
 import bsie.extractor.generic.path
 import bsie.extractor.generic.stat
@@ -68,8 +67,8 @@ class TestPipeline(unittest.TestCase):
         self.assertEqual(hash(pipeline), hash(Pipeline(self.prefix, self.ext2rdr)))
 
         # equivalence respects prefix
-        self.assertNotEqual(pipeline, Pipeline(URI('http://example.com/global/ent#'), self.ext2rdr))
-        self.assertNotEqual(hash(pipeline), hash(Pipeline(URI('http://example.com/global/ent#'), self.ext2rdr)))
+        self.assertNotEqual(pipeline, Pipeline(bsfs.URI('http://example.com/global/ent#'), self.ext2rdr))
+        self.assertNotEqual(hash(pipeline), hash(Pipeline(bsfs.URI('http://example.com/global/ent#'), self.ext2rdr)))
         # equivalence respects extractors/readers
         ext2rdr = {ext: rdr for idx, (ext, rdr) in enumerate(self.ext2rdr.items()) if idx % 2 == 0}
         self.assertNotEqual(pipeline, Pipeline(self.prefix, ext2rdr))
@@ -96,7 +95,7 @@ class TestPipeline(unittest.TestCase):
         pipeline = Pipeline(self.prefix, self.ext2rdr)
         # build objects for tests
         content_hash = 'a948904f2f0f479b8f8197694b30184b0d2ed1c1cd2a1ec0fb85d299a192a447'
-        subject = Node(ns.bsfs.Entity, self.prefix + content_hash)
+        subject = node.Node(ns.bsfs.File, self.prefix + 'file#' + content_hash)
         testfile = os.path.join(os.path.dirname(__file__), 'testfile.t')
         p_filename = pipeline.schema.predicate(ns.bse.filename)
         p_filesize = pipeline.schema.predicate(ns.bse.filesize)