--- a/service/mqtt_to_rdf/inference_test.py	Sat Sep 11 23:21:11 2021 -0700
+++ b/service/mqtt_to_rdf/inference_test.py	Sat Sep 11 23:27:32 2021 -0700
@@ -268,6 +268,19 @@
         valueF = cast(Decimal, vlit.toPython())
         self.assertAlmostEqual(float(valueF), 75.02)
 
+    def testEmitBnodes(self):
+        inf = makeInferenceWithRules('''
+            { ?s a :AirQualitySensor; :label ?name . } => {
+                [ a :MqttStatementSource;
+                :mqttTopic (?name "sensor" "bme280_temperature" "state") ] .
+            } .
+        ''')
+        out = inf.infer(N3('''
+            :airQualityOutdoor a :AirQualitySensor; :label "air_quality_outdoor" .
+        '''))
+
+        self.assertEqual(len(out), 1)
+
 
 class TestListPerformance(WithGraphEqual):
 
@@ -295,6 +308,7 @@
 def fakeStats():
     return defaultdict(lambda: 0)
 
+
 class TestLhsFindCandidateBindings(WithGraphEqual):
 
     def testBnodeMatchesStmt(self):