/
tar_meta_delete.R
107 lines (107 loc) · 2.98 KB
/
tar_meta_delete.R
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
#' @title Delete metadata.
#' @export
#' @family metadata
#' @description Delete the project metadata files from the local file system,
#' the cloud, or both.
#' @inheritParams tar_meta_sync
#' @param delete Character of length 1, which location to delete the files.
#' Choose `"local"` for local files, `"cloud"` for files on the cloud,
#' or `"all"` to delete metadata files from both the local file system
#' and the cloud.
#' @examples
#' if (identical(Sys.getenv("TAR_EXAMPLES"), "true")) { # for CRAN
#' tar_dir({ # tar_dir() runs code from a temp dir for CRAN.
#' tar_script({
#> tar_option_set(
#> resources = tar_resources(
#> aws = tar_resources_aws(
#> bucket = "YOUR_BUCKET_NAME",
#> prefix = "YOUR_PROJECT_NAME"
#> )
#> ),
#> repository = "aws"
#> )
#> list(
#> tar_target(x, data.frame(x = seq_len(2), y = seq_len(2)))
#> )
#' }, ask = FALSE)
#' tar_make()
#' tar_meta_delete()
#' })
#' }
tar_meta_delete <- function(
meta = TRUE,
progress = TRUE,
process = TRUE,
crew = TRUE,
verbose = TRUE,
delete = "all",
script = targets::tar_config_get("script"),
store = targets::tar_config_get("store")
) {
tar_assert_lgl(meta)
tar_assert_scalar(meta)
tar_assert_none_na(meta)
tar_assert_lgl(progress)
tar_assert_scalar(progress)
tar_assert_none_na(progress)
tar_assert_lgl(process)
tar_assert_scalar(process)
tar_assert_none_na(process)
tar_assert_lgl(crew)
tar_assert_scalar(crew)
tar_assert_none_na(crew)
tar_assert_lgl(verbose)
tar_assert_scalar(verbose)
tar_assert_none_na(verbose)
tar_assert_chr(delete)
tar_assert_scalar(delete)
tar_assert_none_na(delete)
tar_assert_nzchar(delete)
tar_assert_in(delete, c("all", "local", "cloud"))
if (delete %in% c("all", "local")) {
tar_assert_scalar(store)
tar_assert_chr(store)
tar_assert_none_na(store)
tar_assert_nzchar(store)
if (meta) {
unlink(path_meta(store))
}
if (progress) {
unlink(path_progress(store))
}
if (process) {
unlink(path_process(store))
}
if (crew) {
unlink(path_crew(store))
}
}
if (delete %in% c("all", "cloud")) {
tar_assert_script(script)
options <- tar_option_script(script = script)
old_repository_meta <- tar_options$get_repository_meta()
old_resources <- tar_options$get_resources()
on.exit({
tar_options$set_repository_meta(old_repository_meta)
tar_options$set_resources(old_resources)
})
tar_options$set_repository_meta(options$repository_meta)
tar_options$set_resources(options$resources)
if (meta) {
database_meta(path_store = tempfile())$delete_cloud(verbose = verbose)
}
if (progress) {
database_progress(path_store = tempfile())$delete_cloud(
verbose = verbose
)
}
if (process) {
database_process(path_store = tempfile())$delete_cloud(verbose = verbose)
}
if (crew) {
database_crew(path_store = tempfile())$delete_cloud(verbose = verbose)
}
}
invisible()
}