Fully reset the workflow.
(self)
| 582 | logger.warning(f"[DAG] Cannot register dependency for unknown atom {atom_name=}") |
| 583 | |
| 584 | def reset(self): |
| 585 | """Fully reset the workflow.""" |
| 586 | self.atoms.clear() |
| 587 | self.context.variables.clear() |
| 588 | self.context.results.clear() |
| 589 | self._component_producers.clear() |
| 590 | self.cache.cache.clear() |
| 591 | self._auto_atom_registry.clear() |
| 592 | self._registered_reactive_atoms.clear() |
| 593 | self._current_atom = None |
| 594 | self._is_rerun = False |
| 595 | |
| 596 | def debug_print_dag(self): |
| 597 | if logger.isEnabledFor(logging.DEBUG): |
no outgoing calls
no test coverage detected