Cleanup flake8 warnings outside of streamz module

Author: dwskoog

docs/source/conf.py

@@ -163,6 +163,3 @@
      author, 'Streamz', 'Support for pipelines managing continuous streams of data.',
      'Miscellaneous'),
 ]
-
-
-

examples/map_failure_modes.py

@@ -28,7 +28,9 @@ async def main(run_flags):
     s_sync.sink(print, sync_source.name)
 
     async_stopping_source = make_counter("async stopping")
-    s_async_stop = async_stopping_source.rate_limit("500ms").map_async(flaky_async, async_stopping_source, stop_on_exception=True)
+    s_async_stop = (async_stopping_source
+                    .rate_limit("500ms")
+                    .map_async(flaky_async, async_stopping_source, stop_on_exception=True))
     s_async_stop.sink(print, async_stopping_source.name)
 
     if run_flags[0]:

examples/river_kmeans.py

@@ -2,21 +2,22 @@
 import random
 import time
 
+import holoviews as hv
 import pandas as pd
-
+import panel as pn
+from hvplot import streamz  # noqa: F401  # this monkeypatches streamz.dataframe
+from panel.pane.holoviews import HoloViews
+from river import cluster
 from streamz import Stream
-import hvplot.streamz
 from streamz.river import RiverTrain
-from river import cluster
-import holoviews as hv
-from panel.pane.holoviews import HoloViews
-import panel as pn
+
 hv.extension('bokeh')
 
 model = cluster.KMeans(n_clusters=3, sigma=0.1, mu=0.5)
 centres = [[random.random(), random.random()] for _ in range(3)]
 count = [0]
 
+
 def gen(move_chance=0.05):
     centre = int(random.random() * 3)  # 3x faster than random.randint(0, 2)
     if random.random() < move_chance:
@@ -101,7 +102,6 @@ def start(event):
 
         def stop(event):
             print(count, "events")
-            global t0
             t_spent = time.time() - t0
             print("frequency", count[0] / t_spent, "Hz")
             print("Current centres", centres)
@@ -128,5 +128,6 @@ def stop(event):
         print("Output centres", [list(c.values()) for c in model.centers.values()])
         s.stop()
 
+
 if __name__ == "__main__":
     main(viz=True)

examples/scrape.py

@@ -14,7 +14,7 @@ def links_of_page(content_page):
     domain = '%s://%s' % (uri.scheme, uri.netloc)
     try:
         soup = BeautifulSoup(content, features="html.parser")
-    except:
+    except Exception:
         return []
     else:
         links = [link.get('href') for link in soup.find_all('a')]