'Test that running a pipeline in chunks produces the same result as if
it were run all at once'

def test_run_chunked_pipeline(self):

    pipe = Pipeline(columns={'close': USEquityPricing.close.latest, 'returns': Returns(window_length=2), 'categorical': USEquityPricing.close.latest.quantiles(5)})
    pipeline_result = self.pipeline_engine.run_pipeline(pipe, start_date=self.PIPELINE_START_DATE, end_date=self.END_DATE)
    chunked_result = self.pipeline_engine.run_chunked_pipeline(pipeline=pipe, start_date=self.PIPELINE_START_DATE, end_date=self.END_DATE, chunksize=22)
    self.assertTrue(chunked_result.equals(pipeline_result))
