From 0196dbeacac298f04c65e024ab5addd137205d9e Mon Sep 17 00:00:00 2001
From: kshakir <kshakir@broadinstitute.org>
Date: Wed, 17 Oct 2012 09:52:17 -0400
Subject: [PATCH] Added more logging to push/pull of RemoteFiles.

---
 .../src/org/broadinstitute/sting/queue/QScript.scala   | 10 ++++++++--
 .../broadinstitute/sting/queue/util/RemoteFile.scala   |  1 +
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/public/scala/src/org/broadinstitute/sting/queue/QScript.scala b/public/scala/src/org/broadinstitute/sting/queue/QScript.scala
index ee2089dc5..2dcfb916c 100755
--- a/public/scala/src/org/broadinstitute/sting/queue/QScript.scala
+++ b/public/scala/src/org/broadinstitute/sting/queue/QScript.scala
@@ -110,12 +110,18 @@ trait QScript extends Logging with PrimitiveOptionConversions with StringFileCon
 
   def pullInputs() {
     val inputs = ClassFieldCache.getFieldFiles(this, inputFields)
-    filterRemoteFiles(inputs).foreach(_.pullToLocal())
+    for (remoteFile <- filterRemoteFiles(inputs)) {
+      logger.info("Pulling %s from %s".format(remoteFile.getAbsolutePath, remoteFile.remoteDescription))
+      remoteFile.pullToLocal()
+    }
   }
 
   def pushOutputs() {
     val outputs = ClassFieldCache.getFieldFiles(this, outputFields)
-    filterRemoteFiles(outputs).foreach(_.pushToRemote())
+    for (remoteFile <- filterRemoteFiles(outputs)) {
+      logger.info("Pushing %s to %s".format(remoteFile.getAbsolutePath, remoteFile.remoteDescription))
+      remoteFile.pushToRemote()
+    }
   }
 
   def remoteOutputs: Map[ArgumentSource, Seq[RemoteFile]] =
diff --git a/public/scala/src/org/broadinstitute/sting/queue/util/RemoteFile.scala b/public/scala/src/org/broadinstitute/sting/queue/util/RemoteFile.scala
index cfe848ba8..9d94975ba 100644
--- a/public/scala/src/org/broadinstitute/sting/queue/util/RemoteFile.scala
+++ b/public/scala/src/org/broadinstitute/sting/queue/util/RemoteFile.scala
@@ -10,4 +10,5 @@ trait RemoteFile extends File with FileExtension {
   def pullToLocal()
   def pushToRemote()
   def deleteRemote()
+  def remoteDescription: String
 }