[CI] SnapshotLifecycleServiceTests testPolicyCRUD failing about elasticsearch HOT 4 CLOSED

            trigger.set(e -> {
                triggeredJobs.add(e.getJobName());
                triggerCount.incrementAndGet();
            });

            final int currentCount2 = triggerCount.get();   // At this point we get the number of jobs. Say it's 2.
            previousState = state;
            // Create a state simulating the policy being deleted
            state = createState(
                new SnapshotLifecycleMetadata(Collections.emptyMap(), OperationMode.RUNNING, new SnapshotLifecycleStats()),
                true
            );
            event = new ClusterChangedEvent("5", state, previousState);
            sls.clusterChanged(event);    // At this point, we cancel any future jobs. But it is entirely possible that a job has run between the first line above and this one. So now triggerCount could be 3 (or even more)
            clock.fastForwardSeconds(2);

            // The existing job should be cancelled and no longer trigger
            assertBusy(() -> assertThat(triggerCount.get(), equalTo(currentCount2))); // If the race condition happened, this will never be true