@@ -967,9 +967,9 @@ trait StandardAsyncExecutionActor
967
967
* @param returnCode The return code.
968
968
* @return True if the return code is for an abort.
969
969
*/
970
- def isAbort (returnCode : Int ): Boolean = returnCode == SIGINT || returnCode == SIGTERM || returnCode == SIGKILL
970
+ def isAbortRc (returnCode : Int ): Boolean = returnCode == SIGINT || returnCode == SIGTERM || returnCode == SIGKILL
971
971
972
- def isOomKill (returnCode : Int ): Boolean = returnCode == SIGKILL || returnCode == SIGCONTAINERKILL
972
+ def isOomKillRc (returnCode : Int ): Boolean = returnCode == SIGKILL || returnCode == SIGCONTAINERKILL
973
973
974
974
/**
975
975
* Custom behavior to run after an abort signal is processed.
@@ -1441,9 +1441,9 @@ trait StandardAsyncExecutionActor
1441
1441
outOfMemoryDetected <- memoryRetryRC
1442
1442
} yield (stderrSize, returnCodeAsString, outOfMemoryDetected)
1443
1443
1444
- stderrSizeAndReturnCodeAndMemoryRetry flatMap { case (stderrSize, returnCodeAsString, stderrOomDetected ) =>
1444
+ stderrSizeAndReturnCodeAndMemoryRetry flatMap { case (stderrSize, returnCodeAsString, isStderrOomDetected ) =>
1445
1445
val tryReturnCodeAsInt = Try (returnCodeAsString.trim.toInt)
1446
- def oomDetected (rc : Int ): Boolean = isOomKill (rc) || stderrOomDetected
1446
+ def isOomDetected (rc : Int ): Boolean = isOomKillRc (rc) || isStderrOomDetected
1447
1447
1448
1448
if (isDone(status)) {
1449
1449
tryReturnCodeAsInt match {
@@ -1459,9 +1459,9 @@ trait StandardAsyncExecutionActor
1459
1459
handleExecutionSuccess(status, oldHandle, returnCodeAsInt)
1460
1460
// A job can receive a SIGKILL (137) if it was aborted or OOM killed. Abort must have been requested for this
1461
1461
// to actually be an abort.
1462
- case Success (returnCodeAsInt) if abortRequested && isAbort (returnCodeAsInt) =>
1462
+ case Success (returnCodeAsInt) if abortRequested && isAbortRc (returnCodeAsInt) =>
1463
1463
Future .successful(AbortedExecutionHandle )
1464
- case Success (returnCodeAsInt) if oomDetected(returnCodeAsInt) && memoryRetryRequested =>
1464
+ case Success (returnCodeAsInt) if memoryRetryRequested && isOomDetected(returnCodeAsInt) =>
1465
1465
val executionHandle = Future .successful(
1466
1466
FailedNonRetryableExecutionHandle (
1467
1467
RetryWithMoreMemory (jobDescriptor.key.tag, stderrAsOption, memoryRetryErrorKeys, log),
@@ -1470,7 +1470,7 @@ trait StandardAsyncExecutionActor
1470
1470
)
1471
1471
)
1472
1472
retryElseFail(executionHandle,
1473
- MemoryRetryResult (oomDetected (returnCodeAsInt), memoryRetryFactor, previousMemoryMultiplier)
1473
+ MemoryRetryResult (isOomDetected (returnCodeAsInt), memoryRetryFactor, previousMemoryMultiplier)
1474
1474
)
1475
1475
case Success (returnCodeAsInt) =>
1476
1476
val executionHandle = Future .successful(
@@ -1491,7 +1491,7 @@ trait StandardAsyncExecutionActor
1491
1491
} else {
1492
1492
tryReturnCodeAsInt match {
1493
1493
case Success (returnCodeAsInt)
1494
- if oomDetected (returnCodeAsInt) && memoryRetryRequested && ! continueOnReturnCode.continueFor(
1494
+ if isOomDetected (returnCodeAsInt) && memoryRetryRequested && ! continueOnReturnCode.continueFor(
1495
1495
returnCodeAsInt
1496
1496
) =>
1497
1497
val executionHandle = Future .successful(
@@ -1502,7 +1502,7 @@ trait StandardAsyncExecutionActor
1502
1502
)
1503
1503
)
1504
1504
retryElseFail(executionHandle,
1505
- MemoryRetryResult (oomDetected (returnCodeAsInt), memoryRetryFactor, previousMemoryMultiplier)
1505
+ MemoryRetryResult (isOomDetected (returnCodeAsInt), memoryRetryFactor, previousMemoryMultiplier)
1506
1506
)
1507
1507
case _ =>
1508
1508
val failureStatus = handleExecutionFailure(status, tryReturnCodeAsInt.toOption)
0 commit comments