zzh
/
gatk-3.8
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Restored RemoteFile push and pull in base QScript.

This commit is contained in:
kshakir 2012-12-04 12:32:00 -05:00
parent 4ced2e4ffc
commit 61bde6210b
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
public/scala/src/org/broadinstitute/sting/queue/QScript.scala
View File

@ -127,14 +127,26 @@ trait QScript extends Logging with PrimitiveOptionConversions with StringFileCon
* Pull all remote files to the local disk * Pull all remote files to the local disk
*/ */
def pullInputs() { def pullInputs() {
val inputs = ClassFieldCache.getFieldFiles(this, inputFields)
for (remoteFile <- filterRemoteFiles(inputs)) {
logger.info("Pulling %s from %s".format(remoteFile.getAbsolutePath, remoteFile.remoteDescription))
remoteFile.pullToLocal()
}
} }
/** /**
* Push all remote files from the local disk * Push all remote files from the local disk
*/ */
def pushOutputs() { def pushOutputs() {
val outputs = ClassFieldCache.getFieldFiles(this, outputFields)
for (remoteFile <- filterRemoteFiles(outputs)) {
logger.info("Pushing %s to %s".format(remoteFile.getAbsolutePath, remoteFile.remoteDescription))
remoteFile.pushToRemote()
}
} }
private def filterRemoteFiles(fields: Seq[File]): Seq[RemoteFile] =
fields.filter(field => field != null && field.isInstanceOf[RemoteFile]).map(_.asInstanceOf[RemoteFile])
/** /**
* @return the inputs or null if there are no inputs * @return the inputs or null if there are no inputs
*/ */