File tree 2 files changed +1
-9
lines changed
main/java/org/elasticsearch/persistent
test/java/org/elasticsearch/persistent
2 files changed +1
-9
lines changed Original file line number Diff line number Diff line change @@ -406,14 +406,6 @@ public Status getStatus() {
406
406
return status ;
407
407
}
408
408
409
- /**
410
- * @return Whether the task status isn't stale. When a task gets unassigned from the executor node or assigned
411
- * to a new executor node and the status hasn't been updated then the task status is stale.
412
- */
413
- public boolean isCurrentStatus () {
414
- return allocationIdOnLastStatusUpdate != null && allocationIdOnLastStatusUpdate == allocationId ;
415
- }
416
-
417
409
@ Override
418
410
public XContentBuilder toXContent (XContentBuilder builder , ToXContent .Params xParams ) throws IOException {
419
411
builder .startObject ();
Original file line number Diff line number Diff line change @@ -202,7 +202,7 @@ public void testPersistentActionStatusUpdate() throws Exception {
202
202
int finalI = i ;
203
203
WaitForPersistentTaskStatusFuture <?> future1 = new WaitForPersistentTaskStatusFuture <>();
204
204
persistentTasksService .waitForPersistentTaskStatus (taskId ,
205
- task -> task != null && task .isCurrentStatus () && task .getStatus ().toString () != null &&
205
+ task -> task != null && task .getStatus () != null && task .getStatus ().toString () != null &&
206
206
task .getStatus ().toString ().equals ("{\" phase\" :\" phase " + (finalI + 1 ) + "\" }" ),
207
207
TimeValue .timeValueSeconds (10 ), future1 );
208
208
assertThat (future1 .get ().getId (), equalTo (taskId ));
You can’t perform that action at this time.
0 commit comments