Skip to content

Commit

Permalink
fix deprecated libraries
Browse files Browse the repository at this point in the history
  • Loading branch information
henriqueribeiro committed Aug 19, 2022
1 parent 3d1d428 commit 87cffaa
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ class EngineJobExecutionActor(replyTo: ActorRef,
log.info(template, jobTag, data.failedCopyAttempts, callCachingParameters.maxFailedCopyAttempts, data.aggregatedHashString)
} else {
log.info(s"BT-322 {} cache hit copying nomatch: could not find a suitable cache hit.", jobTag)
workflowLogger.debug("Could not copy a suitable cache hit for {}. No copy attempts were made.", arg = jobTag)
workflowLogger.debug(s"Could not copy a suitable cache hit for {$jobTag}. No copy attempts were made.")
}

runJob(data)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,6 @@ import cromwell.backend.standard.{StandardAsyncExecutionActor, StandardAsyncExec
import cromwell.backend.OutputEvaluator._

import cromwell.core._
import cromwell.core.path.Path
import cromwell.core.path.{DefaultPathBuilder, Path, PathBuilder, PathFactory}
import cromwell.core.io.{DefaultIoCommandBuilder, IoCommandBuilder}
import cromwell.core.retry.SimpleExponentialBackoff
Expand Down Expand Up @@ -684,7 +683,7 @@ class AwsBatchAsyncBackendJobExecutionActor(override val standardParams: Standar

val exception = new MessageAggregation {
override def exceptionContext: String = "Got Failed RunStatus for success Execution"
override def errorMessages: Traversable[String] = Array("Got Failed RunStatus for success Execution")
override def errorMessages: Iterable[String] = Array("Got Failed RunStatus for success Execution")
}
FailedNonRetryableExecutionHandle(exception, kvPairsToSave = None)
} else {
Expand All @@ -693,7 +692,7 @@ class AwsBatchAsyncBackendJobExecutionActor(override val standardParams: Standar
case InvalidJobOutputs(errors) =>
val exception = new MessageAggregation {
override def exceptionContext: String = "Failed to evaluate job outputs"
override def errorMessages: Traversable[String] = errors.toList
override def errorMessages: Iterable[String] = errors.toList
}
FailedNonRetryableExecutionHandle(exception, kvPairsToSave = None)
case JobOutputsEvaluationException(exception: Exception) if retryEvaluateOutputsAggregated(exception) =>
Expand Down

0 comments on commit 87cffaa

Please sign in to comment.