Back to Community
Notebook run_pipeline() got NotImplementedError (chunksize)

Hi,

In Notebook, I ran run_pipeline() and got the following error (worked before and suddently don't work anymore). Has this something to do with chunksize? Anybody know what this error is and how to solve it? The memory usage is only 27%. Thanks.

NotImplementedErrorTraceback (most recent call last)
in ()
66 start = pd.Timestamp("2015-01-05")
67 end = pd.Timestamp("2017-12-05")
---> 68 results = run_pipeline(pipe, start_date=start, end_date=end)
69 #results.head()
70

/build/src/qexec_repo/qexec/research/api.py in run_pipeline(pipeline, start_date, end_date, chunksize) 479 start_date,
480 end_date,
--> 481 chunksize
482 )
483

/build/src/qexec_repo/qexec/research/_api.pyc in inner_run_pipeline(engine, equity_trading_days, pipeline, start_date, end_date, chunksize) 953 adjusted_start_date,
954 adjusted_end_date,
--> 955 chunksize=chunksize,
956 )
957

/build/src/qexec_repo/zipline_repo/zipline/pipeline/engine.pyc in run_chunked_pipeline(self, pipeline, start_date, end_date, chunksize) 328 chunksize,
329 )
--> 330 chunks = [self.run_pipeline(pipeline, s, e) for s, e in ranges]
331
332 if len(chunks) == 1:

/build/src/qexec_repo/zipline_repo/zipline/pipeline/engine.pyc in run_pipeline(self, pipeline, start_date, end_date) 309 dates,
310 assets,
--> 311 initial_workspace,
312 )
313

/build/src/qexec_repo/zipline_repo/zipline/pipeline/engine.pyc in compute_chunk(self, graph, dates, assets, initial_workspace) 516 mask_dates,
517 assets,
--> 518 mask,
519 )
520 if term.ndim == 2:

/build/src/qexec_repo/zipline_repo/zipline/pipeline/mixins.pyc in _compute(self, windows, dates, assets, mask) 212 inputs = format_inputs(windows, inputs_mask)
213
--> 214 compute(date, masked_assets, out_row, *inputs, **params)
215 out[idx][out_mask] = out_row
216 return out

/build/src/qexec_repo/zipline_repo/zipline/pipeline/mixins.pyc in compute(self, today, assets, out, *arrays) 145 Override this method with a function that writes a value into out.
146 """
--> 147 raise NotImplementedError()
148
149 def _allocate_output(self, windows, shape):

NotImplementedError: