lint

Author: Martin Durant

streamz/collection.py

@@ -240,7 +240,7 @@ def stop(self):
 
     def _ipython_display_(self, **kwargs):
         try:
-            from ipywidgets import Output
+            from ipywidgets import Output  # noqa: F401
             return self.stream.latest().rate_limit(
                 0.5).gather()._ipython_display_(**kwargs)
         except ImportError:

streamz/core.py

@@ -1,5 +1,4 @@
 from __future__ import absolute_import, division, print_function
-import asyncio
 from collections import deque, defaultdict
 from datetime import timedelta
 import functools