Toggle navigation
Home
java.lang.Boolean to com.hubspot.singularity.mesos.StatusUpdateResult
No. of Instances - 3
No. of Commits - 1
No. of Projects - {'Singularity'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Wrap or Un-wrap
whenCompleteAsync
to
whenCompleteAsync
Add or Remove Method invocation
CompletableFuture.supplyAsync(() -> { final String taskId=status.getTaskId().getValue(); final Optional<SingularityTaskId> maybeTaskId=getTaskId(taskId); if (!maybeTaskId.isPresent()) { return false; } schedulerLock.runWithRequestLock(() -> unsafeProcessStatusUpdate(status,maybeTaskId.get()),maybeTaskId.get().getRequestId(),getClass().getSimpleName()); return true; } ,statusUpdatesExecutor)
to
CompletableFuture.supplyAsync(() -> { final String taskId=status.getTaskId().getValue(); final Optional<SingularityTaskId> maybeTaskId=getTaskId(taskId); if (!maybeTaskId.isPresent()) { return StatusUpdateResult.INVALID_TASK_ID; } return schedulerLock.runWithRequestLockAndReturn(() -> unsafeProcessStatusUpdate(status,maybeTaskId.get()),maybeTaskId.get().getRequestId(),getClass().getSimpleName()); } ,statusUpdatesExecutor)
CompletableFuture.supplyAsync(() -> { final String taskId=status.getTaskId().getValue(); final Optional<SingularityTaskId> maybeTaskId=getTaskId(taskId); if (!maybeTaskId.isPresent()) { return false; } schedulerLock.runWithRequestLock(() -> unsafeProcessStatusUpdate(status,maybeTaskId.get()),maybeTaskId.get().getRequestId(),getClass().getSimpleName()); return true; } ,statusUpdatesExecutor)
to
CompletableFuture.supplyAsync(() -> { final String taskId=status.getTaskId().getValue(); final Optional<SingularityTaskId> maybeTaskId=getTaskId(taskId); if (!maybeTaskId.isPresent()) { return StatusUpdateResult.INVALID_TASK_ID; } return schedulerLock.runWithRequestLockAndReturn(() -> unsafeProcessStatusUpdate(status,maybeTaskId.get()),maybeTaskId.get().getRequestId(),getClass().getSimpleName()); } ,statusUpdatesExecutor)