diff --git a/zipline/pipeline/engine.py b/zipline/pipeline/engine.py index 2e4f2e0f..fe56787e 100644 --- a/zipline/pipeline/engine.py +++ b/zipline/pipeline/engine.py @@ -339,9 +339,9 @@ class SimplePipelineEngine(object): key=lambda t: t.dataset ) loader = get_loader(term) - loaded = loader.load_adjusted_array( + loaded = tuple(loader.load_adjusted_array( to_load, mask_dates, assets, mask, - ) + )) assert len(to_load) == len(loaded) for loaded_term, adj_array in zip_longest(to_load, loaded): workspace[loaded_term] = adj_array