| 122 | assert (tmp_dir / "file").read_text() == "modified" |
| 123 | |
| 124 | def test_import_dir(self, tmp_dir, dvc, remote_version_aware): |
| 125 | remote_version_aware.gen({"data_dir": {"subdir": {"file": "file"}}}) |
| 126 | dvc.imp_url("remote://upstream/data_dir", version_aware=True) |
| 127 | stage = first(dvc.index.stages) |
| 128 | assert not stage.outs[0].can_push |
| 129 | assert (tmp_dir / "data_dir" / "subdir" / "file").read_text() == "file" |
| 130 | assert dvc.status() == {} |
| 131 | |
| 132 | dvc.cache.local.clear() |
| 133 | remove(tmp_dir / "data_dir") |
| 134 | dvc.pull() |
| 135 | assert (tmp_dir / "data_dir" / "subdir" / "file").read_text() == "file" |
| 136 | |
| 137 | (remote_version_aware / "data_dir" / "subdir" / "file").write_text("modified") |
| 138 | (remote_version_aware / "data_dir" / "new_file").write_text("new") |
| 139 | assert dvc.status().get("data_dir.dvc") == [ |
| 140 | {"changed deps": {"remote://upstream/data_dir": "modified"}}, |
| 141 | {"changed outs": {"data_dir": "not in cache"}}, |
| 142 | ] |
| 143 | dvc.update(str(tmp_dir / "data_dir.dvc")) |
| 144 | assert (tmp_dir / "data_dir" / "subdir" / "file").read_text() == "modified" |
| 145 | assert (tmp_dir / "data_dir" / "new_file").read_text() == "new" |
| 146 | assert dvc.status() == {} |
| 147 | |
| 148 | dvc.cache.local.clear() |
| 149 | remove(tmp_dir / "data_dir") |
| 150 | dvc.pull() |
| 151 | assert (tmp_dir / "data_dir" / "subdir" / "file").read_text() == "modified" |
| 152 | assert (tmp_dir / "data_dir" / "new_file").read_text() == "new" |
| 153 | |
| 154 | def test_import_no_download(self, tmp_dir, dvc, remote_version_aware, scm): |
| 155 | remote_version_aware.gen({"data_dir": {"subdir": {"file": "file"}}}) |