Unwraps the pipe generator step from config injection and incremental wrappers by restoring the original step. Removes the step with incremental wrapper. Should be used before a subsequent _inject_config is called on the same pipe to successfully wrap it with new incremental and con
(self)
| 686 | pass |
| 687 | |
| 688 | def _eject_config(self) -> bool: |
| 689 | """Unwraps the pipe generator step from config injection and incremental wrappers by restoring the original step. |
| 690 | |
| 691 | Removes the step with incremental wrapper. Should be used before a subsequent _inject_config is called on the |
| 692 | same pipe to successfully wrap it with new incremental and config injection. |
| 693 | Note that resources with bound arguments cannot be ejected. |
| 694 | |
| 695 | """ |
| 696 | if not self._pipe.is_empty and not self._args_bound: |
| 697 | orig_gen = getattr(self._pipe.gen, "__GEN__", None) |
| 698 | if orig_gen: |
| 699 | self._remove_incremental_step() |
| 700 | self._pipe.replace_gen(orig_gen) |
| 701 | return True |
| 702 | return False |
| 703 | |
| 704 | def _inject_config(self, incremental_from_hints_override: Optional[bool] = None) -> Self: |
| 705 | """Wraps the pipe generation step in incremental and config injection wrappers and adds pipe step with |
no test coverage detected