Skip to content

Commit

Permalink
more scalafmt
Browse files Browse the repository at this point in the history
  • Loading branch information
mcovarr committed Jan 30, 2025
1 parent 507ce25 commit b52e3b7
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1083,7 +1083,7 @@ class GcpBatchAsyncBackendJobExecutionActor(override val standardParams: Standar

// returnCode is provided by cromwell, so far, this is empty for all the tests I ran
override def handleExecutionFailure(runStatus: RunStatus, returnCode: Option[Int]): Future[ExecutionHandle] = {
def handleFailedRunStatus(runStatus: RunStatus.UnsuccessfulRunStatus): ExecutionHandle = {
def handleFailedRunStatus(runStatus: RunStatus.UnsuccessfulRunStatus): ExecutionHandle =
runStatus.exitCode match {
case Some(GcpBatchExitCode.VMPreemption) =>
FailedRetryableExecutionHandle(
Expand All @@ -1092,7 +1092,7 @@ class GcpBatchAsyncBackendJobExecutionActor(override val standardParams: Standar
Option(
Seq(
KvPair(ScopedKey(workflowId, futureKvJobKey, GcpBatchBackendLifecycleActorFactory.preemptionCountKey),
"0"
"0"
)
)
)
Expand All @@ -1104,7 +1104,6 @@ class GcpBatchAsyncBackendJobExecutionActor(override val standardParams: Standar
None
)
}
}

Future.fromTry {
Try {
Expand Down

0 comments on commit b52e3b7

Please sign in to comment.