Fix some flake errors

Author: gordonwatts

func_adl/ObjectStream.py

@@ -8,10 +8,13 @@
 import ast
 import os
 
+
 class ObjectStreamException(BaseException):
-    def __init__ (self, msg):
+    'Exception thrown by the ObjectStream object.'
+    def __init__(self, msg):
         BaseException.__init__(self, msg)
 
+
 class ObjectStream:
     r'''
     Represents the AST to produce a stream of objects. The objects can be events,
@@ -176,7 +179,6 @@ def value(self, executor: Callable[[ast.AST], Any] = None) -> Any:
         if fail:
             raise ObjectStreamException('A python async event loop is already running. You must use future_value.')
 
-
         # Run our own event loop to make sure we get back the result and we are self contained
         # and don't stomp on anyone. Since we aren't just waiting on sockets, we will have to
         # have an OS difference here.

tests/test_ObjectStream.py

@@ -31,7 +31,7 @@ def test_simple_query_panda():
         .value(dummy_executor)
     assert isinstance(r, ast.AST)
 
-def test_simple_query_panda():
+def test_simple_query_awkward():
     r = EventDataset("file://junk.root") \
         .SelectMany("lambda e: e.jets()") \
         .Select("lambda j: j.pT()") \