leaky abstractions...patched

zipline/gens/returns.py

@@ -1,5 +1,4 @@
 from collections import defaultdict, deque
-from zipline.transforms.base import BaseTransform
 
 class Returns(object):
     """

zipline/lines.py

@@ -144,7 +144,7 @@ class SimulatedTrading(object):
 
             data_injector = Processor(inject_event_data)
             log_pipeline = NestedSetup([self.zmq_out,data_injector])
-            with log_pipeline.threadbound(), self.stdout_capture(self.logger, ''):
+            with log_pipeline.threadbound(), self.stdout_capture(Logger('Print'), ''):
                 self.stream_results()
             # if no log socket, just run the algo normally
         else:
@@ -234,7 +234,6 @@ class SimulatedTrading(object):
             socket = sock,
         )
 
-
         # This is a class, which is instantiated later
         # in run_algorithm. The class provides a generator.
         self.stdout_capture = stdout_only_pipe