| 177 | |
| 178 | class TestRemoteVersionAware: |
| 179 | def test_file(self, tmp_dir, dvc, run_copy, remote_version_aware): |
| 180 | (stage,) = tmp_dir.dvc_gen("foo", "foo") |
| 181 | run_copy("foo", "foo_copy", name="copy") |
| 182 | |
| 183 | assert dvc.push() |
| 184 | assert (remote_version_aware / "foo").read_text() == "foo" |
| 185 | assert (remote_version_aware / "foo_copy").read_text() == "foo" |
| 186 | foo_dvc = (tmp_dir / "foo.dvc").read_text() |
| 187 | assert "version_id" in foo_dvc |
| 188 | stage = stage.reload() |
| 189 | out = stage.outs[0] |
| 190 | assert out.meta.version_id |
| 191 | dvc_lock = (tmp_dir / "dvc.lock").read_text() |
| 192 | |
| 193 | remove(dvc.cache.local.path) |
| 194 | remove(tmp_dir / "foo") |
| 195 | remove(tmp_dir / "foo_copy") |
| 196 | |
| 197 | assert dvc.pull() |
| 198 | assert (tmp_dir / "foo").read_text() == "foo" |
| 199 | assert (tmp_dir / "foo_copy").read_text() == "foo" |
| 200 | assert (tmp_dir / "foo.dvc").read_text() == foo_dvc |
| 201 | assert (tmp_dir / "dvc.lock").read_text() == dvc_lock |
| 202 | |
| 203 | assert not dvc.push() |
| 204 | assert (remote_version_aware / "foo").read_text() == "foo" |
| 205 | assert (remote_version_aware / "foo_copy").read_text() == "foo" |
| 206 | assert (tmp_dir / "foo.dvc").read_text() == foo_dvc |
| 207 | assert (tmp_dir / "dvc.lock").read_text() == dvc_lock |
| 208 | |
| 209 | dvc.reproduce() |
| 210 | assert not dvc.push() |
| 211 | assert (remote_version_aware / "foo").read_text() == "foo" |
| 212 | assert (remote_version_aware / "foo_copy").read_text() == "foo" |
| 213 | assert (tmp_dir / "foo.dvc").read_text() == foo_dvc |
| 214 | assert (tmp_dir / "dvc.lock").read_text() == dvc_lock |
| 215 | |
| 216 | def test_dir(self, tmp_dir, dvc, run_copy, remote_version_aware): # noqa: PLR0915 |
| 217 | (stage,) = tmp_dir.dvc_gen( |