Use public Registry.refresh() now that it exists.

lsst · Jan 11, 2021 · a0f2fe8 · a0f2fe8
1 parent 0cf2aab
commit a0f2fe8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/tests/test_cmdLineFwk.py b/tests/test_cmdLineFwk.py
@@ -519,7 +519,7 @@ def testSimpleQGraphReplaceRun(self):
         self.assertEqual(taskFactory.countExec, nQuanta)
 
         # need to refresh collections explicitly (or make new butler/registry)
-        butler.registry._collections.refresh()
+        butler.registry.refresh()
         collections = set(butler.registry.queryCollections(...))
         self.assertEqual(collections, {"test", "output", "output/run1"})
 
@@ -539,7 +539,7 @@ def testSimpleQGraphReplaceRun(self):
         args.output_run = "output/run2"
         fwk.runPipeline(copy.deepcopy(qgraph), taskFactory, args)
 
-        butler.registry._collections.refresh()
+        butler.registry.refresh()
         collections = set(butler.registry.queryCollections(...))
         self.assertEqual(collections, {"test", "output", "output/run1", "output/run2"})
 
@@ -558,7 +558,7 @@ def testSimpleQGraphReplaceRun(self):
         args.output_run = "output/run3"
         fwk.runPipeline(copy.deepcopy(qgraph), taskFactory, args)
 
-        butler.registry._collections.refresh()
+        butler.registry.refresh()
         collections = set(butler.registry.queryCollections(...))
         self.assertEqual(collections, {"test", "output", "output/run1", "output/run2", "output/run3"})
 
@@ -581,7 +581,7 @@ def testSimpleQGraphReplaceRun(self):
         args.output_run = "output/run4"
         fwk.runPipeline(copy.deepcopy(qgraph), taskFactory, args)
 
-        butler.registry._collections.refresh()
+        butler.registry.refresh()
         collections = set(butler.registry.queryCollections(...))
         # output/run3 should disappear now
         self.assertEqual(collections, {"test", "output", "output/run1", "output/run2", "output/run4"})