diff --git a/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java b/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java index 5d02fde827160..63c14ac4df96b 100644 --- a/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java +++ b/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java @@ -311,8 +311,9 @@ public void testGeoIpDatabasesDownloadNoGeoipProcessors() throws Exception { .get(); assertTrue(settingsResponse.isAcknowledged()); assertBusy(() -> { - assertNotNull(getTask()); - assertNull(getTask().getState()); + PersistentTasksCustomMetadata.PersistentTask task = getTask(); + assertNotNull(task); + assertNull(task.getState()); putGeoIpPipeline(); // This is to work around the race condition described in #92888 }); putNonGeoipPipeline(pipelineId);