@@ -113,6 +113,27 @@ authenticate <- function(url) {
113
113
get_packit_token_service(url , github_token )
114
114
}
115
115
116
+ run <- function (url , token , ref_name , sha , entry ) {
117
+ if (! is.na(Sys.getenv(" CI" , NA ))) {
118
+ cli :: cli_text(" ::group::Running {entry$name}" )
119
+ withr :: defer(cli :: cli_text(" ::endgroup::" ))
120
+ }
121
+ cli :: cli_rule(" Running {entry$name}" )
122
+
123
+ task_id <- task_run(url , token , ref_name , sha , entry $ name )
124
+ task_wait(url , token , task_id )
125
+ status <- task_status(url , token , task_id , include_logs = TRUE )
126
+
127
+ cli :: cli_verbatim(unlist(status $ logs ))
128
+
129
+ if (status $ status != " COMPLETE" ) {
130
+ cli :: cli_abort(" Task failed" )
131
+ } else {
132
+ cli :: cli_alert_success(" Report ran successfully and produced packet {.href {status$packetId}" )
133
+ cli :: cli_alert_info(" Packit is available at {.url {packet_url}}" )
134
+ }
135
+ }
136
+
116
137
main <- function (args = commandArgs(trailingOnly = TRUE )) {
117
138
url <- args [[1 ]]
118
139
input <- args [[2 ]]
@@ -124,14 +145,7 @@ main <- function(args = commandArgs(trailingOnly = TRUE)) {
124
145
data <- yaml :: read_yaml(file = input )
125
146
126
147
for (entry in data ) {
127
- task_id <- task_run(url , token , ref_name , sha , entry $ name )
128
- task_wait(url , token , task_id )
129
- status <- task_status(url , token , task_id , include_logs = TRUE )
130
- writeLines(unlist(status $ logs ))
131
-
132
- if (status $ status != " COMPLETE" ) {
133
- cli :: cli_abort(" Task failed" )
134
- }
148
+ run(url , token , ref_name , sha , entry )
135
149
}
136
150
}
137
151
0 commit comments