--- a/service/mqtt_to_rdf/mqtt_to_rdf.py	Tue Dec 29 20:53:23 2020 -0800
+++ b/service/mqtt_to_rdf/mqtt_to_rdf.py	Tue Dec 29 20:55:24 2020 -0800
@@ -6,34 +6,29 @@
 from typing import Callable, cast
 
 import cyclone.web
+import prometheus_client
+import rx
+import rx.operators
+import rx.scheduler.eventloop
 from docopt import docopt
 from mqtt_client import MqttClient
-from patchablegraph import (
-    CycloneGraphEventsHandler,
-    CycloneGraphHandler,
-    PatchableGraph,
-)
+from patchablegraph import (CycloneGraphEventsHandler, CycloneGraphHandler, PatchableGraph)
+from prometheus_client import Counter, Gauge, Histogram, Summary
+from prometheus_client.exposition import generate_latest
+from prometheus_client.registry import REGISTRY
 from rdfdb.rdflibpatch import graphFromQuads
-from rdflib import Graph, Literal, Namespace, RDF, URIRef, XSD
+from rdflib import RDF, XSD, Graph, Literal, Namespace, URIRef
 from rdflib.term import Node
-import rx
 from rx.core import Observable
-import rx.operators
-import rx.scheduler.eventloop
 from standardservice.logsetup import log, verboseLogging
 from twisted.internet import reactor
-import prometheus_client
-from prometheus_client import Counter, Gauge, Histogram
-from prometheus_client import Summary
-from prometheus_client.exposition import generate_latest
-from prometheus_client.registry import REGISTRY
 
 from button_events import button_events
 
 ROOM = Namespace('http://projects.bigasterisk.com/room/')
 
+collectors = {}
 
-collectors = {}
 
 def parseDurationLiteral(lit: Literal) -> float:
     if lit.endswith('s'):