Construct and store a PipelineEngine from loader. If get_loader is None, constructs an ExplodingPipelineEngine
(self, get_loader)
| 413 | self._backwards_compat_universe = None |
| 414 | |
| 415 | def init_engine(self, get_loader): |
| 416 | """ |
| 417 | Construct and store a PipelineEngine from loader. |
| 418 | |
| 419 | If get_loader is None, constructs an ExplodingPipelineEngine |
| 420 | """ |
| 421 | if get_loader is not None: |
| 422 | self.engine = SimplePipelineEngine( |
| 423 | get_loader, |
| 424 | self.asset_finder, |
| 425 | self.default_pipeline_domain(self.trading_calendar), |
| 426 | ) |
| 427 | else: |
| 428 | self.engine = ExplodingPipelineEngine() |
| 429 | |
| 430 | def initialize(self, *args, **kwargs): |
| 431 | """ |
no test coverage detected