diff --git a/zipline/gens/returns.py b/zipline/gens/returns.py index ccfc7b00..49d3e9b5 100644 --- a/zipline/gens/returns.py +++ b/zipline/gens/returns.py @@ -1,5 +1,4 @@ from collections import defaultdict, deque -from zipline.transforms.base import BaseTransform class Returns(object): """ diff --git a/zipline/lines.py b/zipline/lines.py index 0fa990ca..5bb50f68 100644 --- a/zipline/lines.py +++ b/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