From c4dfb8d67a6409db8ca274056efdeebbcb94e597 Mon Sep 17 00:00:00 2001 From: Brian Date: Mon, 13 Mar 2017 10:36:22 -0700 Subject: [PATCH] Fixed logs command --- R/task_operation.R | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/R/task_operation.R b/R/task_operation.R index 5e79520..807c0da 100644 --- a/R/task_operation.R +++ b/R/task_operation.R @@ -28,7 +28,7 @@ addTask <- function(jobId, taskId = "default", ...){ stderrUploadCommand <- sprintf("env PATH=$PATH blobxfer %s %s $AZ_BATCH_TASK_DIR/%s --upload --saskey $BLOBXFER_SASKEY --remoteresource %s", storageCredentials$name, jobId, "stderr.txt", paste0("stderr/", taskId, "-stderr.txt")) logsCommand <- sprintf("env PATH=$PATH blobxfer %s %s %s --upload --saskey $BLOBXFER_SASKEY --remoteresource logs/%s", storageCredentials$name, jobId, paste0(taskId, ".txt"), paste0(taskId, ".txt")) - commands <- c("export PATH=/anaconda/envs/py35/bin:$PATH", rCommand, autoUploadCommand, stdoutUploadCommand, stderrUploadCommand, logCommand) + commands <- c("export PATH=/anaconda/envs/py35/bin:$PATH", rCommand, autoUploadCommand, stdoutUploadCommand, stderrUploadCommand, logsCommand) if(taskPrep != ""){ commands <- c(taskPrep, commands) }