def run_graph(self, graph, initial_workspace, mask=None):
        engine = SimplePipelineEngine(
            lambda column: ExplodingObject(),
            self.__calendar,
            self.__finder,
        )
        if mask is None:
            mask = self.__mask

        dates, assets, mask_values = explode(mask)
        initial_workspace.setdefault(AssetExists(), mask_values)
        return engine.compute_chunk(
            graph,
            dates,
            assets,
            initial_workspace,
        )
Open the file in the specified mode
dataset/ETHPy150Open quantopian/zipline/tests/pipeline/base.py/BasePipelineTestCase.run_graph--crossover with--dataset/ETHPy150Open pydata/pandas/pandas/io/pytables.py/HDFStore.open