The AnVIL project is an analysis, visualization, and informatics cloud-based space for data access, sharing and computing across large genomic-related data sets.
For R users with the limited computing resources, we introduce the AnVILWorkflow package. This package allows users to run workflows implemented in Terra without installing software, writing any workflow, or managing cloud resources. Terra is a cloud-based genomics platform and its computing resources rely on Google Cloud Platform (GCP).
Use of this package requires AnVIL and Google cloud computing billing accounts. Consult AnVIL training guides for details on establishing these accounts.
if (!require("BiocManager"))
install.packages("BiocManager")
BiocManager::install("AnVILWorkflow")library(AnVIL)
library(AnVILGCP)
library(AnVILWorkflow)If you use AnVILWorkflow within Terra’s RStudio, you don’t need extra authentication and gcloud SDK. If you use this package locally, it requires gcloud SDK and the billing account used in Terra. You can [install][] the gcloud sdk.
Check whether your system has the installation with AnVIL::gcloud_exists().
It should return TRUE to use AnVILWorkflow package.
gcloud_exists()If it returns FALSE, install the gcloud SDK following this script:
devtools::install_github("rstudio/cloudml")
cloudml::gcloud_install()## shell
$ gcloud auth loginYou need Terra account setup. Once you have your own Terra account, you need two pieces of information to use AnVILWorkflow package:
You can setup your working environment using setCloudEnv() function like
below. Provide the input values with YOUR account information!
accountEmail <- "YOUR_EMAIL@gmail.com"
billingProjectName <- "YOUR_BILLING_ACCOUNT"
setCloudEnv(accountEmail = accountEmail,
billingProjectName = billingProjectName)The remainder of this vignette assumes that an Terra account has been established and successfully linked to a Google cloud computing billing account.
Here is the table of major functions for three workflow steps - prepare, run, and check result.
| Steps | Functions | Description |
|---|---|---|
| Prepare | cloneWorkspace |
Copy the template workspace |
updateInput |
Take user’s inputs | |
| Run | runWorkflow |
Launch the workflow in Terra |
stopWorkflow |
Abort the submission | |
monitorWorkflow |
Monitor the status of your workflow run | |
| Result | getOutput |
List or download your workflow outputs |
You can find all the available workspaces you have access to using
AnVIL::avworkspaces() function. Workspaces manually curated by
this package are separately checked using availableAnalysis() function.
The values under analysis column can be used for the analysis
argument, simplifying the cloning process. For this vignette,
we use "salmon".
> availableAnalysis()
analysis workspaceNamespace workspaceName configuration_namespace configuration_name
1 bioBakery waldronlab-terra-rstudio mtx_workflow_biobakery_version3_template mtx_workflow_biobakery_version3 mtx_workflow_biobakery_version3
2 salmon bioconductor-rpci-anvil Bioconductor-Workflow-DESeq2 bioconductor-rpci-anvil AnVILBulkRNASeq
3 pathml waldronlab-terra-rstudio pathml_stain_normalization_template PathML Preprocessing
description
1 Microbiome analysis using bioBakery
2 Trascript quantification from RNAseq using Salmon | Differential gene expression analysis using DESeq2
3 Stain normalization step of PathML pipelineanalysis <- "salmon"AnVILBrowse("malaria")
AnVILBrowse("resistance")
AnVILBrowse("resistance", searchFrom = "workflow")We will refer the existing workspaces, that you have access to and want
to use for your analysis, as ‘template’ workspaces. The first step of
using this package is cloning the template workspace using cloneWorkspace
function. Note that you need to provide a unique name for the cloned
workspace through workspaceName argument. Once you successfully clone
the workspace, the function will return the name of the cloned workspace.
For example, the successfully execution of the below script will
return {YOUR_BILLING_ACCOUNT}/salmon_test.
salmonWorkspaceName <- basename(tempfile("salmon_")) # unique workspace name
salmonWorkspaceName
cloneWorkspace(workspaceName = salmonWorkspaceName, analysis = analysis)If you want to clone any other workspace that you have access to but
is not curated by this pacakge, you can directly enter the name of
the target workspace as a templateName. For example, to clone the
Tumor_Only_CNV workspace:
cnvWorkspaceName <- basename(tempfile("cnv_")) # unique workspace name
cnvWorkspaceName
cloneWorkspace(workspaceName = cnvWorkspaceName,
templateName = "Tumor_Only_CNV")You can review the current inputs using currentInput function. Below
shows all the required and optional inputs for the workflow.
config <- getWorkflowConfig(workspaceName = salmonWorkspaceName)
current_input <- currentInput(salmonWorkspaceName, config = config)
current_inputYou can modify/update inputs of your workflow using updateInput function. To
minimize the formatting issues, we recommend to make any change in the current
input table returned from the currentInput function. Under the default
(dry=TRUE), the updated input table will be returned without actually
updating Terra/AnVIL. Set dry=FALSE, to make a change in Terra/AnVIL.
new_input <- current_input
new_input[4,4] <- "athal_index"
new_input
updateInput(salmonWorkspaceName, inputs = new_input, config = config)You can launch the workflow using runWorkflow() function. You need to
specify the inputName of your workflow. If you don’t provide it, this
function will return the list of input names you can use for your workflow.
Example error outputs:
runWorkflow(slamonWorkspaceName, config = config)
# You should provide the inputName from the followings:
# [1] "AnVILBulkRNASeq_set"
#> Error in runWorkflow(salmonWorkspaceName):runWorkflow(salmonWorkspaceName,
inputName = "AnVILBulkRNASeq_set",
config = config)The last three columns (status, succeeded, and failed) show the
submission and the result status.
submissions <- monitorWorkflow(workspaceName = salmonWorkspaceName)
submissionsYou can abort the most recently submitted job using the stopWorkflow
function. You can abort any workflow that is not the most recently
submitted by providing a specific submissionId.
stopWorkflow(salmonWorkspaceName)The workspace Bioconductor-Workflow-DESeq2 is the template workspace
you cloned at the beginning using the analysis = "salmon" argument
in cloneWorkspace() function. This template workspace has already a
history of the previous submissions, so we will check the output examples
in this workspace.
submissions <- monitorWorkflow(workspaceName = "Bioconductor-Workflow-DESeq2")
submissionsYou can check all the output files from the most recently succeeded
submission using getOutput function. If you specify the submissionId
argument, you can get the output files of that specific submission.
## Output from the successfully-done submission
successful_submissions <- submissions$submissionId[submissions$succeeded == 1]
out <- getOutput(workspaceName = "Bioconductor-Workflow-DESeq2",
submissionId = successful_submissions[1])head(out)sessionInfo()
#> R Under development (unstable) (2024-10-21 r87258)
#> Platform: x86_64-pc-linux-gnu
#> Running under: Ubuntu 24.04.1 LTS
#>
#> Matrix products: default
#> BLAS: /home/biocbuild/bbs-3.21-bioc/R/lib/libRblas.so
#> LAPACK: /usr/lib/x86_64-linux-gnu/lapack/liblapack.so.3.12.0
#>
#> locale:
#> [1] LC_CTYPE=en_US.UTF-8 LC_NUMERIC=C
#> [3] LC_TIME=en_GB LC_COLLATE=C
#> [5] LC_MONETARY=en_US.UTF-8 LC_MESSAGES=en_US.UTF-8
#> [7] LC_PAPER=en_US.UTF-8 LC_NAME=C
#> [9] LC_ADDRESS=C LC_TELEPHONE=C
#> [11] LC_MEASUREMENT=en_US.UTF-8 LC_IDENTIFICATION=C
#>
#> time zone: America/New_York
#> tzcode source: system (glibc)
#>
#> attached base packages:
#> [1] stats graphics grDevices utils datasets methods base
#>
#> other attached packages:
#> [1] BiocStyle_2.35.0
#>
#> loaded via a namespace (and not attached):
#> [1] miniUI_0.1.1.1 AnVILBase_1.1.0 jsonlite_1.8.9
#> [4] futile.logger_1.4.3 dplyr_1.1.4 compiler_4.5.0
#> [7] BiocManager_1.30.25 promises_1.3.0 BiocBaseUtils_1.9.0
#> [10] Rcpp_1.0.13 tidyselect_1.2.1 parallel_4.5.0
#> [13] tidyr_1.3.1 later_1.3.2 jquerylib_0.1.4
#> [16] yaml_2.3.10 fastmap_1.2.0 mime_0.12
#> [19] R6_2.5.1 generics_0.1.3 httr2_1.0.5
#> [22] knitr_1.48 htmlwidgets_1.6.4 rapiclient_0.1.8
#> [25] tibble_3.2.1 bookdown_0.41 shiny_1.9.1
#> [28] bslib_0.8.0 pillar_1.9.0 rlang_1.1.4
#> [31] utf8_1.2.4 DT_0.33 cachem_1.1.0
#> [34] httpuv_1.6.15 xfun_0.48 sass_0.4.9
#> [37] cli_3.6.3 magrittr_2.0.3 formatR_1.14
#> [40] futile.options_1.0.1 digest_0.6.37 xtable_1.8-4
#> [43] rappdirs_0.3.3 lifecycle_1.0.4 vctrs_0.6.5
#> [46] evaluate_1.0.1 glue_1.8.0 lambda.r_1.2.4
#> [49] AnVIL_1.19.0 fansi_1.0.6 purrr_1.0.2
#> [52] rmarkdown_2.28 httr_1.4.7 tools_4.5.0
#> [55] pkgconfig_2.0.3 htmltools_0.5.8.1