INNER CODE UNIT · Python

_purge_trash

416rehman/DeepZero · src/deepzero/cli.py:239

    def _purge_trash() -> None:
        if not pipeline_def.work_dir.parent.exists():
            return
        for child in pipeline_def.work_dir.parent.iterdir():
            if child.is_dir() and child.name.startswith("trash_"):
                shutil.rmtree(child, ignore_errors=True)

    threading.Thread(target=_purge_trash, daemon=True).start()

    from deepzero.engine.ui import PipelineDashboard

    state_store = StateStore(pipeline_def.work_dir)
    existing_run = state_store.load_run()

    is_resume = existing_run is not None

    dashboard = PipelineDashboard(pipeline_def.stage_names, console=console)
    header_name = (

View source record →