import sys
import logging
from .sources import *


logger = logging.getLogger(__name__)
__version__ = 'v0.0.5.post0'

@@ -110,8 +110,69 @@
 .post0'%0A
+%0Afrom .broker import DataBroker%0Afrom .muxer import DataMuxer%0A

Make DataBroker and DataMuxer top-level.