def METHOD_NAME(self, tmpdir, data_node, job, repo):
    repository = repo()
    repository.base_path = tmpdir
    _DataFSRepository()._save(data_node)
    task = Task("task_config_id", {}, print, [data_node], [data_node])
    _TaskFSRepository()._save(task)
    job._task = task
    for i in range(10):
        job.id = JobId(f"job-{i}")
        repository._save(job)
    assert len(repository._load_all()) == 10
    repository._delete_all()
    assert len(repository._load_all()) == 0