(tmp_dir, dvc, mocker)
| 78 | |
| 79 | |
| 80 | def test_datachain(tmp_dir, dvc, mocker): |
| 81 | datasets = dvc.datasets |
| 82 | |
| 83 | version_info = [MockedDatachainVersionInfo(1), MockedDatachainVersionInfo(2)] |
| 84 | version_info.append(version_info[1]) |
| 85 | mocker.patch("dvc.repo.datasets._get_dataset_info", side_effect=version_info) |
| 86 | |
| 87 | dataset = datasets.add("mydataset", "dataset", "dc") |
| 88 | expected = DatachainDataset( |
| 89 | manifest_path=(tmp_dir / "dvc.yaml").fs_path, |
| 90 | spec=DatasetSpec(name="mydataset", url="dataset", type="dc"), |
| 91 | lock=DatachainDatasetLock( |
| 92 | name="mydataset", |
| 93 | url="dataset", |
| 94 | type="dc", |
| 95 | version=1, |
| 96 | created_at=version_info[0].created_at, |
| 97 | ), |
| 98 | ) |
| 99 | assert "mydataset" in datasets |
| 100 | assert dataset == datasets["mydataset"] == expected |
| 101 | |
| 102 | old, new = datasets.update("mydataset") |
| 103 | assert old == dataset |
| 104 | assert old != new |
| 105 | expected = evolve_recursive( |
| 106 | expected, lock={"version": 2, "created_at": version_info[1].created_at} |
| 107 | ) |
| 108 | assert new == datasets["mydataset"] == expected |
| 109 | |
| 110 | # noop |
| 111 | old, new = datasets.update("mydataset") |
| 112 | assert old == new |
| 113 | |
| 114 | |
| 115 | def test_url(tmp_dir, dvc, mocker): |
nothing calls this directly
no test coverage detected