[stream-refactor] fix flake8 errors

Author: dw

mitogen/__init__.py

@@ -111,10 +111,10 @@ def wrapper(func):
         if profiling:
             mitogen.core.enable_profiling()
             mitogen.master.Router.profiling = profiling
-        utils.log_to_file(level=log_level)
+        mitogen.utils.log_to_file(level=log_level)
         return mitogen.core._profile_hook(
             'app.main',
-            utils.run_with_router,
+            mitogen.utils.run_with_router,
             func,
         )
     return wrapper

mitogen/debug.py

@@ -230,7 +230,7 @@ def _on_debug_msg(self, msg):
     def _handle_debug_msg(self, msg):
         try:
             method, args, kwargs = msg.unpickle()
-            msg.reply(getattr(cls, method)(*args, **kwargs))
+            msg.reply(getattr(self, method)(*args, **kwargs))
         except Exception:
             e = sys.exc_info()[1]
             msg.reply(mitogen.core.CallError(e))

mitogen/unix.py

@@ -85,7 +85,7 @@ def build_stream(cls, router, path=None, backlog=100):
             path = make_socket_path()
         sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
         if os.path.exists(path) and is_path_dead(path):
-            LOG.debug('%r: deleting stale %r', self, path)
+            LOG.debug('%r: deleting stale %r', cls.__name__, path)
             os.unlink(path)
 
         sock.bind(path)